[Fix][Engine] Fix flink engine config issue (#518)

datavane · Feb 20, 2025 · 5247060 · 5247060
1 parent 8cbeadd
commit 5247060
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 1 deletion.
diff --git a/.../src/main/java/io/datavines/engine/flink/config/FlinkMultiTableAccuracyMetricBuilder.java b/.../src/main/java/io/datavines/engine/flink/config/FlinkMultiTableAccuracyMetricBuilder.java
@@ -85,7 +85,7 @@ public void buildSinkConfigs() throws DataVinesException {
                     if (("expected_value_" + metricUniqueKey).equals(metricInputParameter.get(EXPECTED_VALUE))) {
                         metricInputParameter.put(EXPECTED_VALUE, "-1");
                     }
-                    taskSinkSql = taskSinkSql.replaceAll("full join \\$\\{expected_table}","");
+                    taskSinkSql = taskSinkSql.replaceAll("cross join \\$\\{expected_table}","");
                 } else {
                     metricInputParameter.put(EXPECTED_VALUE, "COALESCE(expected_value_" + metricUniqueKey + ", -1)");
                 }

diff --git a/docs/img/wechat-author-qrcode.jpg b/docs/img/wechat-author-qrcode.jpg