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

Inconsistent use of Closure Cleaner in Streaming API

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Blocker
    • Resolution: Fixed
    • Affects Version/s: 0.9
    • Fix Version/s: 0.9
    • Component/s: API / DataStream
    • Labels:
      None

      Description

      In the streaming API operations on DataStream.java call clean() if the closure cleaner is enabled in the execution config. Methods in StreamExecutionEnvironment.java always call clean, no way of disabling it. Operations in the Scala Streaming API also always call clean(), no way of disabling it.

        Attachments

          Activity

            People

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

              Dates

              • Created:
                Updated:
                Resolved: