[flink] 01/03: [hotfix] Fix inactive branch in TtlStateTestBase

[srichter]

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

srichter pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit aee1f182e8fbd311713d1661ab61755b069b1a6c
Author: Stefan Richter <s.rich...@data-artisans.com>
AuthorDate: Tue Mar 19 15:00:50 2019 +0100

    [hotfix] Fix inactive branch in TtlStateTestBase
---
 .../test/java/org/apache/flink/runtime/state/ttl/TtlStateTestBase.java  | 2 +-
 1 file changed, 1 insertion(+), 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
index e6d5ba3..5c92e67 100644
--- 
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 @@ public abstract class TtlStateTestBase {
                // 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);