Flume
  1. Flume
  2. FLUME-1926

Optionally timeout Avro Sink Rpc Clients to avoid stickiness

        Details

        • Type: Improvement Improvement
        • Status: Resolved
        • Priority: Major Major
        • Resolution: Fixed
        • Affects Version/s: None
        • Fix Version/s: v1.4.0
        • Component/s: None
        • Labels:
          None

          Description

          Timing out and killing Rpc Clients will force the Avro Sink to reconnect to the next hop. This will allow the sink to connect to hosts behind a vip when news hosts are added without having to restart the agent.

          1. Text File
            FLUME-1926.patch
            9 kB
            Hari Shreedharan

            Issue Links

            links to

            Web Link Review

              Activity

              Ascending order - Click to sort in descending order
              Hide
              Permalink
              Hari Shreedharan added a comment -

              Patch from rb

              Show
              Hari Shreedharan added a comment - Patch from rb
              Hide
              Permalink
              Juhani Connolly added a comment -

              Tested and committed, thanks Hari!

              Show
              Juhani Connolly added a comment - Tested and committed, thanks Hari!
              Hide
              Permalink
              Hudson added a comment -

              Integrated in flume-trunk #376 (See https://builds.apache.org/job/flume-trunk/376/)
              FLUME-1926. Optionally timeout Avro Sink Rpc Clients to avoid stickiness (Revision ce48a126e8ceebe0fb0eb4048c6b6601688e442d)

              Result = ABORTED
              juhani_connolly : http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=ce48a126e8ceebe0fb0eb4048c6b6601688e442d
              Files :

              • flume-ng-core/src/test/java/org/apache/flume/sink/TestAvroSink.java
              • flume-ng-doc/sphinx/FlumeUserGuide.rst
              • flume-ng-core/src/main/java/org/apache/flume/sink/AbstractRpcSink.java
              Show
              Hudson added a comment - Integrated in flume-trunk #376 (See https://builds.apache.org/job/flume-trunk/376/ ) FLUME-1926 . Optionally timeout Avro Sink Rpc Clients to avoid stickiness (Revision ce48a126e8ceebe0fb0eb4048c6b6601688e442d) Result = ABORTED juhani_connolly : http://git-wip-us.apache.org/repos/asf/flume/repo?p=flume.git&a=commit&h=ce48a126e8ceebe0fb0eb4048c6b6601688e442d Files : flume-ng-core/src/test/java/org/apache/flume/sink/TestAvroSink.java flume-ng-doc/sphinx/FlumeUserGuide.rst flume-ng-core/src/main/java/org/apache/flume/sink/AbstractRpcSink.java

                People

                • Assignee:
                  Hari Shreedharan
                  Reporter:
                  Hari Shreedharan
                • Votes:
                  0 Vote for this issue
                  Watchers:
                  3 Start watching this issue

                  Dates

                  • Created:
                    Updated:
                    Resolved:

                    Development