commit | df46a3f37072a0425157617d4f36a30e52e0f4c0 | [log] [tgz] |
---|---|---|
author | Keith Turner <keith@deenlo.com> | Wed Jan 31 14:00:55 2018 -0500 |
committer | GitHub <noreply@github.com> | Wed Jan 31 14:00:55 2018 -0500 |
tree | d7648881eaf12e2ff186d2afb8a6be3304ff7853 | |
parent | 6bf604fa77593da704121f42242ce45ce13afebe [diff] |
some small fixes for #1001 (#1012)
diff --git a/modules/core/src/main/java/org/apache/fluo/core/impl/TransactionImpl.java b/modules/core/src/main/java/org/apache/fluo/core/impl/TransactionImpl.java index ef13bc8..f4ebacf 100644 --- a/modules/core/src/main/java/org/apache/fluo/core/impl/TransactionImpl.java +++ b/modules/core/src/main/java/org/apache/fluo/core/impl/TransactionImpl.java
@@ -1140,11 +1140,13 @@ } class CommittedTestStep extends CommitStep { + @Override CompletableFuture<Boolean> getMainOp(CommitData cd) { cd.commitObserver.committed(); return CompletableFuture.completedFuture(true); } + @Override CompletableFuture<Void> getFailureOp(CommitData cd) { throw new IllegalStateException("Failure not expected"); }