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/03/19 01:49:38 UTC
[incubator-paimon] branch master updated: [hotfix] Add timeout to 1200 in ChangelogWithKeyFileStoreTableITCase
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 <lz...@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);