Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-2908

NetcatSource - SocketChannel not closed when session is broken

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.3.0
    • Fix Version/s: 1.7.0
    • Component/s: Sinks+Sources
    • Labels:
      None

      Description

      When the NetcatSource socketChannel receives an IOException due to an abruptly closed session the exception is caught but the socketChannel is never closed. This results in leaked sockets and ever growing file descriptors.

      Thanks to Patrick Dvorak for finding the leak.

      1. FLUME-2908.patch
        0.9 kB
        Grant Henke
      2. FLUME-2908-1.patch
        1.0 kB
        Grant Henke

        Issue Links

          Activity

          Hide
          jira-bot ASF subversion and git services added a comment -

          Commit 46ae5accd03e5b8b18d3e1fb52761c1df4e51e5a in flume's branch refs/heads/trunk from Jarek Jarcec Cecho
          [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=46ae5ac ]

          FLUME-2908: NetcatSource - SocketChannel not closed when session is broken

          (Grant Henke via Jarek Jarcec Cecho)

          Show
          jira-bot ASF subversion and git services added a comment - Commit 46ae5accd03e5b8b18d3e1fb52761c1df4e51e5a in flume's branch refs/heads/trunk from Jarek Jarcec Cecho [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=46ae5ac ] FLUME-2908 : NetcatSource - SocketChannel not closed when session is broken (Grant Henke via Jarek Jarcec Cecho)
          Hide
          jira-bot ASF subversion and git services added a comment -

          Commit ad9d4555aaf50e4498390defdce67a92cbf9c31f in flume's branch refs/heads/flume-1.7 from Jarek Jarcec Cecho
          [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=ad9d455 ]

          FLUME-2908: NetcatSource - SocketChannel not closed when session is broken

          (Grant Henke via Jarek Jarcec Cecho)

          Show
          jira-bot ASF subversion and git services added a comment - Commit ad9d4555aaf50e4498390defdce67a92cbf9c31f in flume's branch refs/heads/flume-1.7 from Jarek Jarcec Cecho [ https://git-wip-us.apache.org/repos/asf?p=flume.git;h=ad9d455 ] FLUME-2908 : NetcatSource - SocketChannel not closed when session is broken (Grant Henke via Jarek Jarcec Cecho)
          Hide
          jarcec Jarek Jarcec Cecho added a comment -

          Thank you for your contribution Grant Henke!

          Show
          jarcec Jarek Jarcec Cecho added a comment - Thank you for your contribution Grant Henke !
          Hide
          hudson Hudson added a comment -

          FAILURE: Integrated in Flume-trunk-hbase-1 #157 (See https://builds.apache.org/job/Flume-trunk-hbase-1/157/)
          FLUME-2908: NetcatSource - SocketChannel not closed when session is (jarcec: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=46ae5accd03e5b8b18d3e1fb52761c1df4e51e5a)

          • flume-ng-core/src/main/java/org/apache/flume/source/NetcatSource.java
          Show
          hudson Hudson added a comment - FAILURE: Integrated in Flume-trunk-hbase-1 #157 (See https://builds.apache.org/job/Flume-trunk-hbase-1/157/ ) FLUME-2908 : NetcatSource - SocketChannel not closed when session is (jarcec: http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=46ae5accd03e5b8b18d3e1fb52761c1df4e51e5a ) flume-ng-core/src/main/java/org/apache/flume/source/NetcatSource.java

            People

            • Assignee:
              granthenke Grant Henke
              Reporter:
              granthenke Grant Henke
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development