Skip to content

Commit 6de65f3

Browse files
committed
Add more waits for cache expiry
1 parent 6abf46d commit 6de65f3

File tree

4 files changed

+140
-110
lines changed

4 files changed

+140
-110
lines changed

core/src/integration-test/java/com/scalar/db/transaction/jdbc/JdbcTransactionAdminIntegrationTest.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -499,6 +499,9 @@ protected boolean isIndexOnBlobColumnSupported() {
499499
@Override
500500
protected void transactionalInsert(DistributedTransactionManager manager, Insert insert)
501501
throws TransactionException {
502+
// Wait for cache expiry
503+
Uninterruptibles.sleepUninterruptibly(1, TimeUnit.SECONDS);
504+
502505
DistributedTransaction transaction = manager.start();
503506
transaction.insert(insert);
504507
transaction.commit();
@@ -507,6 +510,9 @@ protected void transactionalInsert(DistributedTransactionManager manager, Insert
507510
@Override
508511
protected List<Result> transactionalScan(DistributedTransactionManager manager, Scan scan)
509512
throws TransactionException {
513+
// Wait for cache expiry
514+
Uninterruptibles.sleepUninterruptibly(1, TimeUnit.SECONDS);
515+
510516
DistributedTransaction transaction = manager.start();
511517
List<Result> results = transaction.scan(scan);
512518
transaction.commit();

0 commit comments

Comments
 (0)