polish

apache · Apr 2, 2024 · 352de15 · 352de15
1 parent 8c7a961
commit 352de15
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...imon-flink-common/src/test/java/org/apache/paimon/flink/action/MergeIntoActionITCase.java b/...imon-flink-common/src/test/java/org/apache/paimon/flink/action/MergeIntoActionITCase.java
@@ -139,8 +139,7 @@ public void testWorkWithPartialUpdate() throws Exception {
         prepareTargetTable(CoreOptions.ChangelogProducer.LOOKUP);
 
         MergeIntoActionBuilder action = new MergeIntoActionBuilder(warehouse, database, "T");
-        // here test if it works when table S is in default and qualified both
-        action.withSourceTable("default.S")
+        action.withSourceTable("S")
                 .withMergeCondition("T.k = S.k AND T.dt = S.dt")
                 .withMatchedUpsert(
                         "T.v <> S.v AND S.v IS NOT NULL", "v = S.v, last_action = 'matched_upsert'")