[ https://issues.apache.org/jira/browse/FLINK-5113?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15735509#comment-15735509 ]
ASF GitHub Bot commented on FLINK-5113: --------------------------------------- Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/2939#discussion_r91719518 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/InterruptSensitiveRestoreTest.java --- @@ -128,11 +131,16 @@ private static Task createTask( when(networkEnvironment.createKvStateTaskRegistry(any(JobID.class), any(JobVertexID.class))) .thenReturn(mock(TaskKvStateRegistry.class)); - ChainedStateHandle<StreamStateHandle> operatorState = new ChainedStateHandle<>(Collections.singletonList(state)); + ChainedStateHandle<StreamStateHandle> operatorState = null; List<KeyGroupsStateHandle> keyGroupStateFromBackend = Collections.emptyList(); List<KeyGroupsStateHandle> keyGroupStateFromStream = Collections.emptyList(); - List<Collection<OperatorStateHandle>> operatorStateBackend = Collections.emptyList(); - List<Collection<OperatorStateHandle>> operatorStateStream = Collections.emptyList(); + + Map<String, long[]> testState = new HashMap<>(); + testState.put("test", new long[] {0, 10}); + + Collection<OperatorStateHandle> handle = Collections.singletonList(new OperatorStateHandle(testState, state)); + List<Collection<OperatorStateHandle>> operatorStateBackend = Collections.singletonList(handle); + List<Collection<OperatorStateHandle>> operatorStateStream = Collections.singletonList(handle); --- End diff -- Can this be an empty list as well? > Make all Testing Functions implement CheckpointedFunction Interface. > -------------------------------------------------------------------- > > Key: FLINK-5113 > URL: https://issues.apache.org/jira/browse/FLINK-5113 > Project: Flink > Issue Type: Improvement > Components: DataStream API > Affects Versions: 1.2.0 > Reporter: Kostas Kloudas > Assignee: Kostas Kloudas > Fix For: 1.2.0 > > > Currently stateful functions implement the (old) Checkpointed interface. > This is issue aims at porting all these function to the new > CheckpointedFunction interface, so that they can leverage the new > capabilities by it. -- This message was sent by Atlassian JIRA (v6.3.4#6332)