You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2019/01/08 14:06:48 UTC
[flink] 04/04: [FLINK-11280] [state backends,
tests] Do not set current key before restore in TtlStateTestBase
tests
This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 31685a36d1344e34c37b678c0335d560ccf6f4f4
Author: Tzu-Li (Gordon) Tai <tz...@apache.org>
AuthorDate: Tue Jan 8 13:42:34 2019 +0100
[FLINK-11280] [state backends, tests] Do not set current key before restore in TtlStateTestBase tests
---
.../org/apache/flink/runtime/state/ttl/StateBackendTestContext.java | 3 +--
.../test/java/org/apache/flink/runtime/state/ttl/TtlStateTestBase.java | 3 +++
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/StateBackendTestContext.java b/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/StateBackendTestContext.java
index eaec234..c1de3cb 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/StateBackendTestContext.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/StateBackendTestContext.java
@@ -76,9 +76,8 @@ public abstract class StateBackendTestContext {
keyedStateBackend = stateBackend.createKeyedStateBackend(
env, new JobID(), "test", StringSerializer.INSTANCE, 10,
new KeyGroupRange(0, 9), env.getTaskKvStateRegistry(), timeProvider);
- keyedStateBackend.setCurrentKey("defaultKey");
} catch (Exception e) {
- throw new RuntimeException("unexpected");
+ throw new RuntimeException("unexpected", e);
}
}
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 f9f108a..9b6882a 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
@@ -113,6 +113,7 @@ public abstract class TtlStateTestBase {
this.ttlConfig = ttlConfig;
sbetc.createAndRestoreKeyedStateBackend();
sbetc.restoreSnapshot(null);
+ sbetc.setCurrentKey("defaultKey");
createState();
ctx().initTestValues();
}
@@ -129,6 +130,7 @@ public abstract class TtlStateTestBase {
KeyedStateHandle snapshot = sbetc.takeSnapshot();
sbetc.createAndRestoreKeyedStateBackend();
sbetc.restoreSnapshot(snapshot);
+ sbetc.setCurrentKey("defaultKey");
createState();
}
@@ -397,6 +399,7 @@ public abstract class TtlStateTestBase {
sbetc.createAndRestoreKeyedStateBackend();
sbetc.restoreSnapshot(snapshot);
+ sbetc.setCurrentKey("defaultKey");
sbetc.createState(ctx().createStateDescriptor(), "");
}