This is an automated email from the ASF dual-hosted git repository.

domgarguilo pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/elasticity by this push:
     new e44f47c9ac Fix AccumuloStoreFateIT.testCreateWithKeyInProgress (#4291)
e44f47c9ac is described below

commit e44f47c9ac4e714bc654e91be1f3476123830939
Author: Dom G <domgargu...@apache.org>
AuthorDate: Thu Feb 22 10:14:36 2024 -0500

    Fix AccumuloStoreFateIT.testCreateWithKeyInProgress (#4291)
    
    * added the expected status to the txStore before calling delete()
---
 .../main/java/org/apache/accumulo/test/fate/accumulo/FateStoreIT.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/test/src/main/java/org/apache/accumulo/test/fate/accumulo/FateStoreIT.java 
b/test/src/main/java/org/apache/accumulo/test/fate/accumulo/FateStoreIT.java
index deda053717..3edd8717e9 100644
--- a/test/src/main/java/org/apache/accumulo/test/fate/accumulo/FateStoreIT.java
+++ b/test/src/main/java/org/apache/accumulo/test/fate/accumulo/FateStoreIT.java
@@ -332,7 +332,7 @@ public abstract class FateStoreIT extends 
SharedMiniClusterBase implements FateT
     FateKey fateKey = FateKey.forSplit(ke);
 
     FateTxStore<TestEnv> txStore = 
store.createAndReserve(fateKey).orElseThrow();
-    ;
+
     try {
       assertTrue(txStore.timeCreated() > 0);
       txStore.setStatus(TStatus.IN_PROGRESS);
@@ -342,6 +342,7 @@ public abstract class FateStoreIT extends 
SharedMiniClusterBase implements FateT
       assertTrue(create(store, fateKey).isEmpty());
       assertEquals(TStatus.IN_PROGRESS, txStore.getStatus());
     } finally {
+      txStore.setStatus(TStatus.SUCCESSFUL);
       txStore.delete();
       txStore.unreserve(0, TimeUnit.SECONDS);
     }

Reply via email to