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

Flink Create Functions call Collector.close()

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: P2
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.1.0-incubating
    • Component/s: runner-flink
    • Labels:
      None

      Description

      Collector.close() should only be called internally, by Flink. Calling close() in the user function, as we do in FlinkCreateFunction and FlinkStreamingCreateFunction will lead to downstream operations being closed twice, which can lead to faulty behavior.

        Attachments

          Activity

            People

            • Assignee:
              aljoscha Aljoscha Krettek
              Reporter:
              aljoscha Aljoscha Krettek
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: