|
|
@@ -4127,7 +4127,7 @@ public class InternalEngineTests extends EngineTestCase {
|
|
|
assertThat(noOpResult.getSeqNo(), equalTo(seqNo));
|
|
|
assertThat(noOpResult.getTerm(), equalTo(term));
|
|
|
engine.refresh("test");
|
|
|
- Engine.DeleteResult deleteResult = engine.delete(replicaDeleteForDoc("id", 1, 2, randomNonNegativeLong()));
|
|
|
+ Engine.DeleteResult deleteResult = engine.delete(replicaDeleteForDoc("id", 1, seqNo + between(1, 1000), randomNonNegativeLong()));
|
|
|
assertThat(deleteResult.getFailure(), nullValue());
|
|
|
engine.refresh("test");
|
|
|
}
|
|
|
@@ -4153,10 +4153,11 @@ public class InternalEngineTests extends EngineTestCase {
|
|
|
assertThat(delete.getFailure(), nullValue());
|
|
|
break;
|
|
|
case NO_OP:
|
|
|
- Engine.NoOpResult noOp = engine.noOp(new Engine.NoOp(i, primaryTerm.get(),
|
|
|
+ long seqNo = i;
|
|
|
+ Engine.NoOpResult noOp = engine.noOp(new Engine.NoOp(seqNo, primaryTerm.get(),
|
|
|
randomFrom(Engine.Operation.Origin.values()), randomNonNegativeLong(), ""));
|
|
|
assertThat(noOp.getTerm(), equalTo(primaryTerm.get()));
|
|
|
- assertThat(noOp.getSeqNo(), equalTo((long) i));
|
|
|
+ assertThat(noOp.getSeqNo(), equalTo(seqNo));
|
|
|
assertThat(noOp.getFailure(), nullValue());
|
|
|
break;
|
|
|
default:
|