[Bug-4117][core]Bug fix for debug task when target table contains '.' (…

…#4118)
DataLinkDC · Jan 7, 2025 · 7df416c · 7df416c
1 parent 14049f2
commit 7df416c
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/dinky-core/src/main/java/org/dinky/explainer/mock/MockStatementExplainer.java b/dinky-core/src/main/java/org/dinky/explainer/mock/MockStatementExplainer.java
@@ -165,14 +165,14 @@ private String getSinkMockDdlStatement(String tableName, String columns) {
 
     /**
      * generate table identifier with mocked prefix info
-     * @param tableName table name
+     * @param tableIdentifier table identifier
      * @return table identifier with mocked prefix info
      */
-    private List<String> generateMockedTableIdentifier(String tableName) {
+    private List<String> generateMockedTableIdentifier(String tableIdentifier) {
         List<String> names = new ArrayList<>();
         names.add("default_catalog");
         names.add("default_database");
-        names.add("mock_sink_" + tableName);
+        names.add("mock_sink_" + tableIdentifier.replace(".", "_"));
         return names;
     }
 }