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. Text File
            FLUME-2908.patch
            0.9 kB
            Grant Henke
          2. Text File
            FLUME-2908-1.patch
            1.0 kB
            Grant Henke

            Issue Links

            links to

            Web Link https://reviews.apache.org/r/47021

              Activity

              Ascending order - Click to sort in descending order
              Hide
              Permalink
              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
              Permalink
              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
              Permalink
              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
              Permalink
              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