Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-8571

Provide an enhanced KeyedStream implementation to use ForwardPartitioner

    Details

    • Type: Improvement
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.4.1, 1.5.0
    • Component/s: None
    • Labels:
      None

      Description

      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.

        Attachments

          Activity

            People

            • Assignee:
              srichter Stefan Richter
              Reporter:
              gvnagarjun Nagarjun Guraja
            • Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: