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 58ab961be99bdf92d0c67e0567983678075553c3 Author: Lei Zhang <[email protected]> AuthorDate: Tue Mar 8 17:57:27 2022 +0800 SCB-2421 Fix test case for slow CI --- .../pack/alpha/fsm/SagaIntegrationTest.java | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java b/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java index b642eb9..a94760b 100644 --- a/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java +++ b/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/SagaIntegrationTest.java @@ -94,7 +94,7 @@ public class SagaIntegrationTest { SagaEventSender.successfulEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system) .getLastSagaData(); return sagaData != null && sagaData.isTerminated() @@ -122,7 +122,7 @@ public class SagaIntegrationTest { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED; }); @@ -141,7 +141,7 @@ public class SagaIntegrationTest { SagaEventSender.middleTxAbortedEvents(globalTxId, localTxId_1, localTxId_2).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED; }); @@ -162,7 +162,7 @@ public class SagaIntegrationTest { SagaEventSender.lastTxAbortedEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED; }); @@ -184,7 +184,7 @@ public class SagaIntegrationTest { SagaEventSender.sagaAbortedEventBeforeTxComponsitedEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED; }); @@ -206,7 +206,7 @@ public class SagaIntegrationTest { SagaEventSender.receivedRemainingEventAfterFirstTxAbortedEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED; }); @@ -228,7 +228,7 @@ public class SagaIntegrationTest { SagaEventSender.sagaAbortedEventAfterAllTxEndedsEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED; }); @@ -250,7 +250,7 @@ public class SagaIntegrationTest { SagaEventSender.omegaSendSagaTimeoutEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.SUSPENDED; }); @@ -273,7 +273,7 @@ public class SagaIntegrationTest { SagaEventSender.sagaActorTriggerTimeoutEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3, timeout).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(timeout + 10, SECONDS).until(() -> { + await().atMost(timeout + 60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.SUSPENDED; }); @@ -295,7 +295,7 @@ public class SagaIntegrationTest { SagaEventSender.successfulWithTxConcurrentEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMMITTED; }); @@ -339,7 +339,7 @@ public class SagaIntegrationTest { SagaEventSender.lastTxAbortedEventWithTxConcurrentEvents(globalTxId, localTxId_1, localTxId_2, localTxId_3).stream().forEach( event -> { memoryActorEventChannel.send(event); }); - await().atMost(10, SECONDS).until(() -> { + await().atMost(60, SECONDS).until(() -> { SagaData sagaData = SagaDataExtension.SAGA_DATA_EXTENSION_PROVIDER.get(system).getLastSagaData(); return sagaData !=null && sagaData.isTerminated() && sagaData.getLastState()==SagaActorState.COMPENSATED; });
