You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@paimon.apache.org by lz...@apache.org on 2023/05/11 10:33:54 UTC
[incubator-paimon] branch master updated: [hotfix] Fix failed test PartialUpdateITCase#testForeignKeyJoin (#1133)
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
The following commit(s) were added to refs/heads/master by this push:
new fe5d91173 [hotfix] Fix failed test PartialUpdateITCase#testForeignKeyJoin (#1133)
fe5d91173 is described below
commit fe5d9117347ac82e8cab87a166a10fe6da8b6cc0
Author: yuzelin <33...@users.noreply.github.com>
AuthorDate: Thu May 11 18:33:49 2023 +0800
[hotfix] Fix failed test PartialUpdateITCase#testForeignKeyJoin (#1133)
---
.../src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java
index f7f42a06a..fb12b8ec6 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java
+++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/PartialUpdateITCase.java
@@ -46,8 +46,8 @@ public class PartialUpdateITCase extends CatalogITCaseBase {
"CREATE TABLE IF NOT EXISTS dwd_orders ("
+ "OrderID INT, OrderNumber INT, PersonID INT, LastName STRING, FirstName STRING, Age INT, PRIMARY KEY (OrderID) NOT ENFORCED)"
+ " WITH ('merge-engine'='partial-update', 'partial-update.ignore-delete'='true');",
- "CREATE TABLE IF NOT EXISTS ods_orders (OrderID INT, OrderNumber INT, PersonID INT, PRIMARY KEY (OrderID) NOT ENFORCED) WITH ('changelog-producer'='input');",
- "CREATE TABLE IF NOT EXISTS dim_persons (PersonID INT, LastName STRING, FirstName STRING, Age INT, PRIMARY KEY (PersonID) NOT ENFORCED) WITH ('changelog-producer'='input');");
+ "CREATE TABLE IF NOT EXISTS ods_orders (OrderID INT, OrderNumber INT, PersonID INT, PRIMARY KEY (OrderID) NOT ENFORCED) WITH ('changelog-producer'='input', 'continuous.discovery-interval'='1s');",
+ "CREATE TABLE IF NOT EXISTS dim_persons (PersonID INT, LastName STRING, FirstName STRING, Age INT, PRIMARY KEY (PersonID) NOT ENFORCED) WITH ('changelog-producer'='input', 'continuous.discovery-interval'='1s');");
}
@Test