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

Support transcoding for Flatten in Flink Runner

    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Open
    • Priority: P3
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: runner-flink
    • Labels:
      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

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                mxm Maximilian Michels
              • Votes:
                0 Vote for this issue
                Watchers:
                1 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