You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2023/02/22 10:56:38 UTC
[flink-table-store] branch master updated: [hotfix] Increase slots to 8 in AbstractTestBase
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/flink-table-store.git
The following commit(s) were added to refs/heads/master by this push:
new 1882577a [hotfix] Increase slots to 8 in AbstractTestBase
1882577a is described below
commit 1882577a850f365e098998b4973b5cc8d72917c2
Author: Shammon FY <zj...@gmail.com>
AuthorDate: Wed Feb 22 18:56:31 2023 +0800
[hotfix] Increase slots to 8 in AbstractTestBase
This closes #552
---
.../org/apache/flink/table/store/connector/util/AbstractTestBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/util/AbstractTestBase.java b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/util/AbstractTestBase.java
index b6f2b396..457e97f3 100644
--- a/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/util/AbstractTestBase.java
+++ b/flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/util/AbstractTestBase.java
@@ -40,7 +40,7 @@ public class AbstractTestBase extends TestLogger {
private static final Logger LOG = LoggerFactory.getLogger(AbstractTestBase.class);
- private static final int DEFAULT_PARALLELISM = 4;
+ private static final int DEFAULT_PARALLELISM = 8;
@RegisterExtension
protected static final MiniClusterWithClientExtension MINI_CLUSTER_EXTENSION =