File tree Expand file tree Collapse file tree 5 files changed +7
-7
lines changed
datasources/src/main/java/org/opensearch/sql/datasources/utils
opensearch/src/main/java/org/opensearch/sql/opensearch Expand file tree Collapse file tree 5 files changed +7
-7
lines changed Original file line number Diff line number Diff line change 1313import org .opensearch .transport .client .node .NodeClient ;
1414import static org .opensearch .sql .opensearch .executor .OpenSearchQueryManager .SQL_WORKER_THREAD_POOL_NAME ;
1515
16- /** The scheduler which schedule the task run in sql_worker thread pool. */
16+ /** The scheduler which schedule the task run in sql-worker thread pool. */
1717@ UtilityClass
1818public class Scheduler {
1919 public static void schedule (NodeClient client , Runnable task ) {
Original file line number Diff line number Diff line change @@ -31,4 +31,4 @@ Parser parse raw query as Statement and create AbstractPlan. Each AbstractPlan d
3131### Change of existing logic
32321 . Remove the schedule logic in NIO thread. After the change,
3333 a. Parser will be executed in NIO thread.
34- b. QueryManager decide query execution strategy. e.g. OpenSearchQueryManager schedule the QueryExecution running in ** sql_worker ** thread pool.
34+ b. QueryManager decide query execution strategy. e.g. OpenSearchQueryManager schedule the QueryExecution running in ** sql-worker ** thread pool.
Original file line number Diff line number Diff line change @@ -223,19 +223,19 @@ The SQL plugin is integrated with the `OpenSearch Thread Pool Settings <https://
223223There are two thread pools which can be configured on cluster setup via `settings.yml `::
224224
225225 thread_pool:
226- sql_worker :
226+ sql-worker :
227227 size: 30
228228 queue_size: 100
229229 sql_background_io:
230230 size: 30
231231 queue_size: 1000
232232
233- The ``sql_worker `` pool corresponds to compute resources related to running queries, such as compute-heavy evaluations on result sets.
233+ The ``sql-worker `` pool corresponds to compute resources related to running queries, such as compute-heavy evaluations on result sets.
234234This directly maps to the number of queries that can be run concurrently.
235235This is the primary pool you interact with externally.
236236``sql_background_io `` is a low-footprint pool for IO requests the plugin makes,
237237and can be used to limit indirect load that SQL places on your cluster for Calcite-enabled operations.
238- A ``sql_worker `` thread may spawn multiple background threads.
238+ A ``sql-worker `` thread may spawn multiple background threads.
239239
240240plugins.query.executionengine.spark.session.limit
241241==================================================
Original file line number Diff line number Diff line change @@ -219,7 +219,7 @@ public void cleanup(OpenSearchRequest request) {
219219
220220 @ Override
221221 public void schedule (Runnable task ) {
222- // at that time, task already running the sql_worker ThreadPool.
222+ // at that time, task already running the sql-worker ThreadPool.
223223 task .run ();
224224 }
225225
Original file line number Diff line number Diff line change @@ -21,7 +21,7 @@ public class OpenSearchQueryManager implements QueryManager {
2121
2222 private final NodeClient nodeClient ;
2323
24- public static final String SQL_WORKER_THREAD_POOL_NAME = "sql_worker " ;
24+ public static final String SQL_WORKER_THREAD_POOL_NAME = "sql-worker " ;
2525 public static final String SQL_BACKGROUND_THREAD_POOL_NAME = "sql_background_io" ;
2626
2727 @ Override
You can’t perform that action at this time.
0 commit comments