This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a commit to branch ignite-19497
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/ignite-19497 by this push:
new db12e598b5 minor.
db12e598b5 is described below
commit db12e598b5412f77d194487529d8228aa257edfb
Author: amashenkov <[email protected]>
AuthorDate: Thu Aug 10 16:56:30 2023 +0300
minor.
---
.../java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java
b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java
index b502e6fef5..63b2cd08c2 100644
---
a/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java
+++
b/modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlQueryProcessor.java
@@ -404,7 +404,7 @@ public class SqlQueryProcessor implements QueryProcessor {
CompletableFuture<AsyncSqlCursor<List<Object>>> stage = start
//TODO: IGNITE-19499 Drop next line. Force direct config
lookup on late node to avoid race.
.thenCompose(ignored -> tableManager.tablesAsync())
- .thenCompose(ignored -> {
+ .thenComposeAsync(ignored -> {
ParsedResult result = parserService.parse(sql);
validateParsedStatement(context, outerTx, result, params);
@@ -468,7 +468,7 @@ public class SqlQueryProcessor implements QueryProcessor {
}
);
});
- });
+ }, taskExecutor);
stage.whenComplete((cur, ex) -> {
if (ex instanceof CancellationException) {
