Preserving indices causes seqNo to increase for jobs that aren't full…

…y cleaned up (#397)
opendistro-for-elasticsearch · Feb 1, 2021 · f8ecd25 · f8ecd25
1 parent cf7881f
commit f8ecd25
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...csearch/indexmanagement/indexstatemanagement/resthandler/IndexStateManagementRestApiIT.kt b/...csearch/indexmanagement/indexstatemanagement/resthandler/IndexStateManagementRestApiIT.kt
@@ -200,7 +200,7 @@ class IndexStateManagementRestApiIT : IndexStateManagementRestTestCase() {
         val updatedSeqNo = (responseBody[_SEQ_NO] as Int).toLong()
         assertNotEquals("response is missing Id", Policy.NO_ID, updatedId)
         assertEquals("not same id", policy.id, updatedId)
-        assertEquals("incorrect seqNo", policy.seqNo + 1, updatedSeqNo)
+        assertTrue("incorrect seqNo", policy.seqNo < updatedSeqNo)
     }
 
     @Throws(Exception::class)

diff --git a/.../opendistroforelasticsearch/indexmanagement/rollup/resthandler/RestIndexRollupActionIT.kt b/.../opendistroforelasticsearch/indexmanagement/rollup/resthandler/RestIndexRollupActionIT.kt
@@ -121,7 +121,7 @@ class RestIndexRollupActionIT : RollupRestTestCase() {
         val updatedSeqNo = (responseBody[_SEQ_NO] as Int).toLong()
         assertNotEquals("response is missing Id", Rollup.NO_ID, updatedId)
         assertEquals("not same id", rollup.id, updatedId)
-        assertEquals("incorrect seqNo", rollup.seqNo + 1, updatedSeqNo)
+        assertTrue("incorrect seqNo", rollup.seqNo < updatedSeqNo)
     }
 
     @Throws(Exception::class)