Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-6523

Support transcoding for Flatten in Flink Runner

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Open
    • P3
    • Resolution: Unresolved
    • None
    • None
    • runner-flink
    • None

    Description

      The Beam documentation mentions that Flatten does not require coders of all inputs to be of the same type, as long as the result type is the same. However, the current implementation in the Flink Runner requires all coders to match.

      Attachments

        Issue Links

          blocks

          Sub-task - The sub-task of the issue BEAM-7319 Multiple NeedsRunner tests break with Flink 'Cannot union streams of different types'

          • P3 - Non-urgent bugs, features, and improvements
          • Open
          is cloned by

          New Feature - A new feature of the product, which has yet to be developed. BEAM-7236 Support transcoding for Flatten in Spark Runner

          • P3 - Non-urgent bugs, features, and improvements
          • Open
          relates to

          Bug - A problem which impairs or prevents the functions of the product. BEAM-7793 BagState drops Rows when triggered by timer

          • P2 - Default priority. Will be triaged and planned according to community practices.
          • Resolved
          links to

          Web Link GitHub Pull Request #7646

          Activity

            People

              Unassigned Unassigned
              mxm Maximilian Michels
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 1h 20m
                  1h 20m