ascherbakoff commented on code in PR #7799:
URL: https://github.com/apache/ignite-3/pull/7799#discussion_r3051631061
##########
modules/runner/src/integrationTest/java/org/apache/ignite/internal/table/ItDataConsistencyTest.java:
##########
@@ -50,19 +58,20 @@ public class ItDataConsistencyTest extends
ClusterPerClassIntegrationTest {
private static final String ZONE_NAME = "test_zone";
private static final String TABLE_NAME = "accounts";
private static final int WRITE_PARALLELISM =
Runtime.getRuntime().availableProcessors();
- private static final int READ_PARALLELISM = 1;
+ private static final int READ_PARALLELISM = 0;
private static final int ACCOUNTS_COUNT = WRITE_PARALLELISM * 10;
private static final double INITIAL = 1000;
private static final double TOTAL = ACCOUNTS_COUNT * INITIAL;
- private static final int DURATION_MILLIS = 10000;
+ private static final int DURATION_MILLIS = 30000;
private CyclicBarrier startBar = new CyclicBarrier(WRITE_PARALLELISM +
READ_PARALLELISM, () -> log.info("Before test"));
private LongAdder ops = new LongAdder();
private LongAdder fails = new LongAdder();
+ private LongAdder restarts = new LongAdder();
private LongAdder readOps = new LongAdder();
private LongAdder readFails = new LongAdder();
private AtomicBoolean stop = new AtomicBoolean();
- private Random rng = new Random();
+ private Random rng = new Random(0);
Review Comment:
🆗
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
