lowka commented on code in PR #5210:
URL: https://github.com/apache/ignite-3/pull/5210#discussion_r1952732415
##########
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/PrepareServiceImpl.java:
##########
@@ -226,21 +227,29 @@ public CompletableFuture<QueryPlan> prepareAsync(
assert schemaName != null;
- SchemaPlus schema =
schemaManager.schema(operationContext.operationTime().longValue())
- .getSubSchema(schemaName);
-
- if (schema == null) {
- return CompletableFuture.failedFuture(new
SchemaNotFoundException(schemaName));
+ IgniteSchemas rootSchema =
schemaManager.schemas(operationContext.operationTime().longValue());
+ if (rootSchema == null) {
+ return CompletableFuture.failedFuture(new
SchemaNotFoundException("Root schema"));
Review Comment:
Thanks. Replaced it with an assertion because it looks like this is not
possible as missing catalog version leads to a `CatalogNotFoundException`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: notifications-unsubscr...@ignite.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
