Correct correlated variable detection process

suibianwanwank · Jan 16, 2025 · 957de76 · 957de76
1 parent cb67294
commit 957de76
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/src/main/java/org/apache/calcite/rel/metadata/RelMdColumnOrigins.java b/core/src/main/java/org/apache/calcite/rel/metadata/RelMdColumnOrigins.java
@@ -32,6 +32,7 @@
 import org.apache.calcite.rel.core.TableFunctionScan;
 import org.apache.calcite.rel.core.TableModify;
 import org.apache.calcite.rel.core.TableScan;
+import org.apache.calcite.rex.RexCorrelVariable;
 import org.apache.calcite.rex.RexFieldAccess;
 import org.apache.calcite.rex.RexInputRef;
 import org.apache.calcite.rex.RexLocalRef;
@@ -308,7 +309,10 @@ private RelMdColumnOrigins() {}
           }
 
           @Override public Void visitFieldAccess(RexFieldAccess fieldAccess) {
-            throw Util.FoundOne.NULL;
+            if (fieldAccess.getReferenceExpr() instanceof RexCorrelVariable) {
+              throw Util.FoundOne.NULL;
+            }
+            return null;
           }
         };
     try {