[ https://issues.apache.org/jira/browse/FLINK-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15715164#comment-15715164 ]
ASF GitHub Bot commented on FLINK-5163: --------------------------------------- Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/2871#discussion_r90641264 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/SourceFunctionTest.java --- @@ -52,12 +52,4 @@ public void fromCollectionTest() throws Exception { Arrays.asList(1, 2, 3)))); assertEquals(expectedList, actualList); } - --- End diff -- I think it would be good to have a snapshot/restore test for this source, verifying that we see all the expected elements (no matter the order). > Make the production functions rescalable (apart from the Rolling/Bucketing > Sinks) > --------------------------------------------------------------------------------- > > Key: FLINK-5163 > URL: https://issues.apache.org/jira/browse/FLINK-5163 > Project: Flink > Issue Type: Improvement > Affects Versions: 1.2.0 > Reporter: Kostas Kloudas > Assignee: Kostas Kloudas > Fix For: 1.2.0 > > > This issue targets porting all the functions in the production code to the > new state abstractions. These functions are: > 1) StatefulSequenceSource > 2) MessageAcknowledgingSourceBase > 3) FromElementsFunction > 4) ContinuousFileMonitoringFunction -- This message was sent by Atlassian JIRA (v6.3.4#6332)