opensearch-project/opensearch-spark
View on GitHubRemove usage of SessionManager from JobOperator
Open
#1,050 opened on Feb 13, 2025
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.