[hotfix] Fix inactive branch in TtlStateTestBase

kaywa · Mar 20, 2019 · aee1f18 · aee1f18
1 parent 21cff1d
commit aee1f18
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlStateTestBase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/TtlStateTestBase.java
@@ -515,7 +515,7 @@ private void triggerMoreIncrementalCleanupByOtherOps() throws Exception {
 		// trigger more cleanup by doing something out side of INC_CLEANUP_ALL_KEYS
 		for (int i = INC_CLEANUP_ALL_KEYS; i < INC_CLEANUP_ALL_KEYS * 2; i++) {
 			sbetc.setCurrentKey(Integer.toString(i));
-			if (i / 2 == 0) {
+			if (i % 2 == 0) {
 				ctx().get();
 			} else {
 				ctx().update(ctx().updateEmpty);