Repository: ignite Updated Branches: refs/heads/master fe9fe5dce -> 822c3b1ee
IGNITE-7714: SQL COPY command: fixed "Table not found" issue on the client node. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/822c3b1e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/822c3b1e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/822c3b1e Branch: refs/heads/master Commit: 822c3b1eed9b9cde15e3e381f7a4dc0b04a90403 Parents: fe9fe5d Author: devozerov <[email protected]> Authored: Thu Feb 15 14:00:42 2018 +0300 Committer: devozerov <[email protected]> Committed: Thu Feb 15 14:00:42 2018 +0300 ---------------------------------------------------------------------- .../processors/query/h2/DmlStatementsProcessor.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/822c3b1e/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/DmlStatementsProcessor.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/DmlStatementsProcessor.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/DmlStatementsProcessor.java index c46c906..224bae0 100644 --- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/DmlStatementsProcessor.java +++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/DmlStatementsProcessor.java @@ -1016,9 +1016,16 @@ public class DmlStatementsProcessor { GridH2Table tbl = idx.dataTable(cmd.schemaName(), cmd.tableName()); - if (tbl == null) + if (tbl == null) { + idx.kernalContext().cache().createMissingQueryCaches(); + + tbl = idx.dataTable(cmd.schemaName(), cmd.tableName()); + } + + if (tbl == null) { throw new IgniteSQLException("Table does not exist: " + cmd.tableName(), IgniteQueryErrorCode.TABLE_NOT_FOUND); + } UpdatePlan plan = UpdatePlanBuilder.planForBulkLoad(cmd, tbl);
