[ https://issues.apache.org/jira/browse/FLINK-8571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16356863#comment-16356863 ]
ASF GitHub Bot commented on FLINK-8571: --------------------------------------- Github user aljoscha commented on a diff in the pull request: https://github.com/apache/flink/pull/5424#discussion_r166915376 --- Diff: flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/DataStreamTest.scala --- @@ -649,6 +651,18 @@ class DataStreamTest extends AbstractTestBase { assert(sg.getIterationSourceSinkPairs.size() == 2) } + @Test + def testReinterpretAsKeyedStream(): Unit = { --- End diff -- So far, this file is a suite of tests, we never execute Flink programs, which should only happen in ITCases, IMO. > Provide an enhanced KeyedStream implementation to use ForwardPartitioner > ------------------------------------------------------------------------ > > Key: FLINK-8571 > URL: https://issues.apache.org/jira/browse/FLINK-8571 > Project: Flink > Issue Type: Improvement > Reporter: Nagarjun Guraja > Assignee: Stefan Richter > Priority: Major > > This enhancement would help in modeling problems with pre partitioned input > sources(for e.g. Kafka with Keyed topics). This would help in making the job > graph embarrassingly parallel while leveraging rocksdb state backend and also > the fine grained recovery semantics. -- This message was sent by Atlassian JIRA (v7.6.3#76005)