[
https://issues.apache.org/jira/browse/FLINK-6830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16038461#comment-16038461
]
ASF GitHub Bot commented on FLINK-6830:
---------------------------------------
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4059#discussion_r120305797
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/state/operator/restore/unkeyed/ChainBreakTest.java
---
@@ -31,8 +36,22 @@
/**
* Verifies that the state of all operators is restored if a topology
change breaks up a chain.
*/
+@RunWith(Parameterized.class)
public class ChainBreakTest extends
AbstractNonKeyedOperatorRestoreTestBase {
+ private final String savepointPath;
+
+ @Parameterized.Parameters(name = "Migrate Savepoint: {0}")
+ public static Collection<String> parameters () {
--- End diff --
Will change!
> Add ITTests for savepoint migration from 1.3
> --------------------------------------------
>
> Key: FLINK-6830
> URL: https://issues.apache.org/jira/browse/FLINK-6830
> Project: Flink
> Issue Type: Test
> Components: State Backends, Checkpointing
> Affects Versions: 1.3.0
> Reporter: Tzu-Li (Gordon) Tai
> Assignee: Tzu-Li (Gordon) Tai
> Fix For: 1.3.1
>
>
> Already with FLINK-6763 and FLINK-6764 we'll need to change the serialization
> formats between 1.3.0 and 1.3.x.
> We probably should add the stateful job migration ITCases for restoring from
> Flink 1.3.x now.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
