[flink] 01/03: [hotfix] Fix inactive branch in TtlStateTestBase
This is an automated email from the ASF dual-hosted git repository.
srichter pushed a commit to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 0ced11c8be7ccaf5112f3e050406cf75d5e55637
Author: Stefan Richter
AuthorDate: Tue Mar 19 15:00:50 2019 +0100
[hotfix] Fix inactive branch in TtlStateTestBase
(cherry picked from commit aee1f182e8fbd311713d1661ab61755b069b1a6c)
---
.../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);
[flink] 01/03: [hotfix] Fix inactive branch in TtlStateTestBase
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
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);
