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

Unclosed InputStream in OperatorSnapshotUtil#readStateHandle()

    Details

      Description

          FileInputStream in = new FileInputStream(path);
          DataInputStream dis = new DataInputStream(in);
      

      None of the in / dis is closed upon return from the method.

      In writeStateHandle(), OutputStream should be closed in finally block.

        Attachments

          Activity

            People

            • Assignee:
              zjureel Fang Yong
              Reporter:
              yuzhihong@gmail.com Ted Yu
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: