You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2022/09/08 06:51:16 UTC

[shardingsphere] branch master updated: Extended time, avoid deadlock (#20877)

This is an automated email from the ASF dual-hosted git repository.

zhaojinchao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new f8d211524dc Extended time, avoid deadlock (#20877)
f8d211524dc is described below

commit f8d211524dc871533769871d549b360e7c221ea6
Author: Xinze Guo <10...@users.noreply.github.com>
AuthorDate: Thu Sep 8 14:51:05 2022 +0800

    Extended time, avoid deadlock (#20877)
---
 .../data/pipeline/cases/migration/AbstractMigrationITCase.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/migration/AbstractMigrationITCase.java b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/migration/AbstractMigrationITCase.java
index 4b7487773bc..05d525474fe 100644
--- a/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/migration/AbstractMigrationITCase.java
+++ b/shardingsphere-test/shardingsphere-integration-test/shardingsphere-integration-test-scaling/src/test/java/org/apache/shardingsphere/integration/data/pipeline/cases/migration/AbstractMigrationITCase.java
@@ -107,9 +107,9 @@ public abstract class AbstractMigrationITCase extends BaseITCase {
     
     protected void startMigrationOrderCopy(final boolean withSchema) throws SQLException {
         if (withSchema) {
-            proxyExecuteWithLog(migrationDistSQLCommand.getMigrationOrderCopySingleTableWithSchema(), 1);
+            proxyExecuteWithLog(migrationDistSQLCommand.getMigrationOrderCopySingleTableWithSchema(), 4);
         } else {
-            proxyExecuteWithLog(migrationDistSQLCommand.getMigrationOrderCopySingleTable(), 1);
+            proxyExecuteWithLog(migrationDistSQLCommand.getMigrationOrderCopySingleTable(), 4);
         }
     }