[incubator-paimon] branch master updated: [hotfix] Add timeout to 1200 in ChangelogWithKeyFileStoreTableITCase

[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 a1e122e64 [hotfix] Add timeout to 1200 in 
ChangelogWithKeyFileStoreTableITCase
a1e122e64 is described below

commit a1e122e64c4012d5db67c78fb5d7ed4877b61b9e
Author: JingsongLi <lzljs3620...@aliyun.com>
AuthorDate: Sun Mar 19 09:49:28 2023 +0800

    [hotfix] Add timeout to 1200 in ChangelogWithKeyFileStoreTableITCase
---
 .../ChangelogWithKeyFileStoreTableITCase.java      | 22 +++++++++++-----------
 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ChangelogWithKeyFileStoreTableITCase.java
 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ChangelogWithKeyFileStoreTableITCase.java
index 8aa129e0b..ce3ce41ce 100644
--- 
a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ChangelogWithKeyFileStoreTableITCase.java
+++ 
b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/ChangelogWithKeyFileStoreTableITCase.java
@@ -96,7 +96,7 @@ public class ChangelogWithKeyFileStoreTableITCase extends 
AbstractTestBase {
     // ------------------------------------------------------------------------
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testFullCompactionTriggerInterval() throws Exception {
         innerTestChangelogProducing(
                 Arrays.asList(
@@ -105,7 +105,7 @@ public class ChangelogWithKeyFileStoreTableITCase extends 
AbstractTestBase {
     }
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testFullCompactionWithLongCheckpointInterval() throws 
Exception {
         // create table
         TableEnvironment bEnv = createBatchTableEnvironment();
@@ -169,7 +169,7 @@ public class ChangelogWithKeyFileStoreTableITCase extends 
AbstractTestBase {
     }
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testLookupChangelog() throws Exception {
         
innerTestChangelogProducing(Collections.singletonList("'changelog-producer' = 
'lookup'"));
     }
@@ -248,14 +248,14 @@ public class ChangelogWithKeyFileStoreTableITCase extends 
AbstractTestBase {
     // ------------------------------------------------------------------------
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testNoChangelogProducerBatchRandom() throws Exception {
         TableEnvironment bEnv = createBatchTableEnvironment();
         testNoChangelogProducerRandom(bEnv, 1, false);
     }
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testNoChangelogProducerStreamingRandom() throws Exception {
         ThreadLocalRandom random = ThreadLocalRandom.current();
         TableEnvironment sEnv = 
createStreamingTableEnvironment(random.nextInt(900) + 100);
@@ -263,14 +263,14 @@ public class ChangelogWithKeyFileStoreTableITCase extends 
AbstractTestBase {
     }
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testFullCompactionChangelogProducerBatchRandom() throws 
Exception {
         TableEnvironment bEnv = createBatchTableEnvironment();
         testFullCompactionChangelogProducerRandom(bEnv, 1, false);
     }
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testFullCompactionChangelogProducerStreamingRandom() throws 
Exception {
         ThreadLocalRandom random = ThreadLocalRandom.current();
         TableEnvironment sEnv = 
createStreamingTableEnvironment(random.nextInt(900) + 100);
@@ -278,7 +278,7 @@ public class ChangelogWithKeyFileStoreTableITCase extends 
AbstractTestBase {
     }
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testStandAloneFullCompactJobRandom() throws Exception {
         ThreadLocalRandom random = ThreadLocalRandom.current();
         TableEnvironment sEnv = 
createStreamingTableEnvironment(random.nextInt(900) + 100);
@@ -286,14 +286,14 @@ public class ChangelogWithKeyFileStoreTableITCase extends 
AbstractTestBase {
     }
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testLookupChangelogProducerBatchRandom() throws Exception {
         TableEnvironment bEnv = createBatchTableEnvironment();
         testLookupChangelogProducerRandom(bEnv, 1, false);
     }
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testLookupChangelogProducerStreamingRandom() throws Exception {
         ThreadLocalRandom random = ThreadLocalRandom.current();
         TableEnvironment sEnv = 
createStreamingTableEnvironment(random.nextInt(900) + 100);
@@ -301,7 +301,7 @@ public class ChangelogWithKeyFileStoreTableITCase extends 
AbstractTestBase {
     }
 
     @Test
-    @Timeout(600)
+    @Timeout(1200)
     public void testStandAloneLookupJobRandom() throws Exception {
         ThreadLocalRandom random = ThreadLocalRandom.current();
         TableEnvironment sEnv = 
createStreamingTableEnvironment(random.nextInt(900) + 100);