update

IGinX-THU · Feb 10, 2025 · 7cdba4c · 7cdba4c
1 parent 745b19c
commit 7cdba4c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/...va/cn/edu/tsinghua/iginx/engine/physical/storage/execute/StoragePhysicalTaskExecutor.java b/...va/cn/edu/tsinghua/iginx/engine/physical/storage/execute/StoragePhysicalTaskExecutor.java
@@ -146,7 +146,6 @@ private StoragePhysicalTaskExecutor() {
                               boolean isDummyStorageUnit = task.isDummyStorageUnit();
                               DataArea dataArea =
                                   new DataArea(storageUnit, fragmentMeta.getKeyInterval());
-                              List<Operator> remainingOperators = new ArrayList<>();
                               switch (op.getType()) {
                                 case Project:
                                   PushDownStrategy strategy =

diff --git a/dataSource/relational/src/main/java/cn/edu/tsinghua/iginx/relational/RelationalStorage.java b/dataSource/relational/src/main/java/cn/edu/tsinghua/iginx/relational/RelationalStorage.java
@@ -1762,10 +1762,14 @@ && filterContainsType(Arrays.asList(FilterType.Value, FilterType.Path), filter))
             String fullQuotColumnNames = getQuotColumnNames(entry.getValue());
             List<String> fullPathList = Arrays.asList(entry.getValue().split(", "));
             fullPathList.replaceAll(s -> RelationSchema.getFullName(tableName, s));
+            List<String> fullQuotePathList = Arrays.asList(entry.getValue().split(", "));
+            fullQuotePathList.replaceAll(
+                s -> RelationSchema.getQuoteFullName(tableName, s, relationalMeta.getQuote()));
+
             String filterStr =
                 filterTransformer.toString(
                     dummyFilterSetTrueByColumnNames(expandFilter.copy(), fullPathList));
-            String concatKey = buildConcat(fullPathList);
+            String concatKey = buildConcat(fullQuotePathList);
             statement =
                 String.format(
                     relationalMeta.getConcatQueryStatement(),