opensearch-project/opensearch-spark

Remove usage of SessionManager from JobOperator

Open

#1,050 opened on Feb 13, 2025

View on GitHub
 (1 comment) (0 reactions) (1 assignee)Scala (55 forks)auto 404
good first issuemaintenance

Repository metrics

Stars
 (43 stars)
PR merge metrics
 (PR metrics pending)

Description

The JobOperator.scala has been refactored to support all types of queries. To facilitate interactive queries, the query result writer was made dependent on the sessionManager, leading to the introduction of sessionManager in JobOperator.scala.

However, as per @noCharger comment on this PR, we can use SingleStatementExecutionManagerImpl instead. This would eliminate the dependency on sessionManager.

Contributor guide