Try to fix the Travis CI build error

apache · Aug 17, 2019 · 6ab3a53 · 6ab3a53
1 parent 06d837d
commit 6ab3a53
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...er/src/test/java/org/apache/servicecomb/pack/alpha/server/tcc/AlphaTccServerTestBase.java b/...er/src/test/java/org/apache/servicecomb/pack/alpha/server/tcc/AlphaTccServerTestBase.java
@@ -248,16 +248,16 @@ public void assertOnSwitchOtherCallbackInstance() {
         .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());
     blockingStub.onParticipationStarted(newParticipationStartedEvent());
     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"));