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

ningjiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git

commit 6ab3a539f83cb0d8d3b850375fa6bc5ade1f18a0
Author: Willem Jiang <[email protected]>
AuthorDate: Sat Aug 17 11:22:30 2019 +0800

    Try to fix the Travis CI build error
---
 .../servicecomb/pack/alpha/server/tcc/AlphaTccServerTestBase.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/alpha/alpha-server/src/test/java/org/apache/servicecomb/pack/alpha/server/tcc/AlphaTccServerTestBase.java
 
b/alpha/alpha-server/src/test/java/org/apache/servicecomb/pack/alpha/server/tcc/AlphaTccServerTestBase.java
index df5161b..9aada8a 100644
--- 
a/alpha/alpha-server/src/test/java/org/apache/servicecomb/pack/alpha/server/tcc/AlphaTccServerTestBase.java
+++ 
b/alpha/alpha-server/src/test/java/org/apache/servicecomb/pack/alpha/server/tcc/AlphaTccServerTestBase.java
@@ -248,8 +248,8 @@ public abstract class AlphaTccServerTestBase {
         .build();
     asyncStub.onConnected(config, commandStreamObserver);
 
-    await().atMost(1, SECONDS).until(() -> 
(OmegaCallbacksRegistry.getRegistry().get(serviceName) != null));
-    await().atMost(1, SECONDS).until(() -> 
(OmegaCallbacksRegistry.getRegistry().get(serviceName).size() == 2));
+    await().atMost(2, SECONDS).until(() -> 
(OmegaCallbacksRegistry.getRegistry().get(serviceName) != null));
+    await().atMost(2, SECONDS).until(() -> 
(OmegaCallbacksRegistry.getRegistry().get(serviceName).size() == 2));
 
     OmegaCallbacksRegistry.getRegistry().get(serviceName).remove(instanceId);
     blockingStub.onTccTransactionStarted(newTxStart());
@@ -257,7 +257,7 @@ public abstract class AlphaTccServerTestBase {
     blockingStub.onParticipationEnded(newParticipationEndedEvent("Succeed"));
     GrpcAck result = blockingStub.onTccTransactionEnded(newTxEnd("Succeed"));
 
-    await().atMost(2, SECONDS).until(() -> !receivedCommands.isEmpty());
+    await().atMost(4, SECONDS).until(() -> !receivedCommands.isEmpty());
     assertThat(receivedCommands.size(), is(1));
     GrpcTccCoordinateCommand command = receivedCommands.poll();
     assertThat(command.getMethod(), is("confirm"));

Reply via email to