Nagarjun Guraja created FLINK-8571: -------------------------------------- Summary: 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
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)