(incubator-paimon) branch master updated: [flink][test] Fix unstable test of GlobalDynamicBucketTableITCase (#2378)

[lzljs3620320]

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 23f98e55e [flink][test] Fix unstable test of 
GlobalDynamicBucketTableITCase (#2378)
23f98e55e is described below

commit 23f98e55eea95b0318383e54ddf270a8021e95ed
Author: YeJunHao <41894543+leaves12...@users.noreply.github.com>
AuthorDate: Thu Nov 23 19:07:52 2023 +0800

    [flink][test] Fix unstable test of GlobalDynamicBucketTableITCase (#2378)
---
 .github/workflows/check-licensing.yml                   |  2 +-
 .../paimon/flink/GlobalDynamicBucketTableITCase.java    | 17 +++++++++++++++--
 2 files changed, 16 insertions(+), 3 deletions(-)

diff --git a/.github/workflows/check-licensing.yml 
b/.github/workflows/check-licensing.yml
index 5ad1915d5..494a772e8 100644
--- a/.github/workflows/check-licensing.yml
+++ b/.github/workflows/check-licensing.yml
@@ -41,7 +41,7 @@ jobs:
         run: |
           set -o pipefail
 
-          mvn clean deploy ${{ env.MVN_COMMON_OPTIONS }} 
-Dmaven.test.skip=true \
+          mvn clean deploy ${{ env.MVN_COMMON_OPTIONS }} -DskipTests \
             -DaltDeploymentRepository=validation_repository::default::file:${{ 
env.MVN_VALIDATION_DIR }} \
             | tee ${{ env.MVN_BUILD_OUTPUT_FILE }}
 
diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/GlobalDynamicBucketTableITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/GlobalDynamicBucketTableITCase.java
index fc6172b7a..c908efc4e 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/GlobalDynamicBucketTableITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/GlobalDynamicBucketTableITCase.java
@@ -76,8 +76,8 @@ public class GlobalDynamicBucketTableITCase extends 
CatalogITCaseBase {
                         + " (1, 1, 1, 1),"
                         + " (2, 1, 2, 3),"
                         + " (1, 3, 3, 3),"
-                        + " (2, 4, 4, 4),"
-                        + " (3, 3, CAST(NULL AS INT), 5)");
+                        + " (2, 4, 4, 4)");
+        sql("INSERT INTO partial_update_t VALUES (3, 3, CAST(NULL AS INT), 
5)");
         assertThat(sql("SELECT * FROM partial_update_t"))
                 .containsExactlyInAnyOrder(
                         Row.of(1, 1, 2, 3), Row.of(2, 4, 4, 4), Row.of(1, 3, 
3, 5));
@@ -87,6 +87,19 @@ public class GlobalDynamicBucketTableITCase extends 
CatalogITCaseBase {
                 .containsExactlyInAnyOrder(Row.of(1, 1, 1), Row.of(1, 3, 3), 
Row.of(2, 4, 4));
     }
 
+    @Test
+    public void testBulkLoad2() {
+        sql(
+                "INSERT INTO partial_update_t VALUES"
+                        + " (1, 3, 1, 1),"
+                        + " (2, 3, 2, 3),"
+                        + " (1, 3, 3, 3),"
+                        + " (2, 3, 4, 4)");
+        sql("INSERT INTO partial_update_t VALUES (3, 3, CAST(NULL AS INT), 
5)");
+        assertThat(sql("SELECT * FROM partial_update_t"))
+                .containsExactlyInAnyOrder(Row.of(1, 3, 4, 5));
+    }
+
     @Test
     public void testWriteRead() {
         sql("INSERT INTO T VALUES (1, 1, 1), (1, 2, 2), (1, 3, 3), (1, 4, 4), 
(1, 5, 5)");