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 =