|
30 | 30 | import java.lang.management.OperatingSystemMXBean;
|
31 | 31 | import java.lang.reflect.Method;
|
32 | 32 | import java.net.URI;
|
33 |
| -import java.time.Duration; |
34 | 33 | import java.util.ArrayList;
|
35 | 34 | import java.util.Arrays;
|
36 | 35 | import java.util.HashMap;
|
@@ -99,7 +98,6 @@ abstract class AbstractStressTestBase<C extends AbstractContext>
|
99 | 98 |
|
100 | 99 | private static final int BIG_DATA_TEST_NODE_COUNT = Integer.getInteger( "bigDataTestNodeCount", 30_000 );
|
101 | 100 | private static final int BIG_DATA_TEST_BATCH_SIZE = Integer.getInteger( "bigDataTestBatchSize", 10_000 );
|
102 |
| - private static final Duration DEFAULT_BLOCKING_TIME_OUT = Duration.ofMinutes( 10 ); |
103 | 101 |
|
104 | 102 | private LoggerNameTrackingLogging logging;
|
105 | 103 | private ExecutorService executor;
|
@@ -638,7 +636,7 @@ private Bookmark createNodesRx( int batchCount, int batchSize, InternalDriver dr
|
638 | 636 |
|
639 | 637 | Flux.concat( Flux.range( 0, batchCount ).map( batchIndex ->
|
640 | 638 | session.writeTransaction( tx -> createNodesInTxRx( tx, batchIndex, batchSize ) )
|
641 |
| - ) ).blockLast( DEFAULT_BLOCKING_TIME_OUT ); // throw any error if happened |
| 639 | + ) ).blockLast(); // throw any error if happened |
642 | 640 |
|
643 | 641 | long end = System.nanoTime();
|
644 | 642 | System.out.println( "Node creation with reactive API took: " + NANOSECONDS.toMillis( end - start ) + "ms" );
|
@@ -673,7 +671,7 @@ private void readNodesRx( InternalDriver driver, Bookmark bookmark, int expected
|
673 | 671 | verifyNodeProperties( node );
|
674 | 672 | } ).then() );
|
675 | 673 |
|
676 |
| - Flux.from( readQuery ).blockLast( DEFAULT_BLOCKING_TIME_OUT ); |
| 674 | + Flux.from( readQuery ).blockLast(); |
677 | 675 |
|
678 | 676 | assertEquals( expectedNodeCount, nodesSeen.get() );
|
679 | 677 |
|
|
0 commit comments