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

Support transcoding for Flatten in Flink Runner

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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

              Dates

              • Created:
                Updated:

                Time Tracking

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

                  Issue deployment