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. FLUME-1926.patch
        9 kB
        Hari Shreedharan

        Issue Links

          Activity

          Hari Shreedharan created issue -
          Hide
          Hari Shreedharan added a comment -

          Patch from rb

          Show
          Hari Shreedharan added a comment - Patch from rb
          Hari Shreedharan made changes -
          Field Original Value New Value
          Attachment FLUME-1926.patch [ 12572674 ]
          Hari Shreedharan made changes -
          Status Open [ 1 ] Patch Available [ 10002 ]
          Assignee Hari Shreedharan [ hshreedharan ]
          Hide
          Juhani Connolly added a comment -

          Tested and committed, thanks Hari!

          Show
          Juhani Connolly added a comment - Tested and committed, thanks Hari!
          Juhani Connolly made changes -
          Status Patch Available [ 10002 ] Resolved [ 5 ]
          Resolution Fixed [ 1 ]
          Hari Shreedharan made changes -
          Remote Link This issue links to "Review (Web Link)" [ 12078 ]
          Hide
          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
          Mike Percy made changes -
          Fix Version/s v1.3.0 [ 12322140 ]
          Mike Percy made changes -
          Issue Type Bug [ 1 ] Improvement [ 4 ]
          Fix Version/s v1.4.0 [ 12323372 ]
          Fix Version/s v1.3.0 [ 12322140 ]
          Transition Time In Source Status Execution Times Last Executer Last Execution Date
          Open Open Patch Available Patch Available
          10d 3h 1 Hari Shreedharan 08/Mar/13 01:57
          Patch Available Patch Available Resolved Resolved
          6d 4h 6m 1 Juhani Connolly 14/Mar/13 06:03

            People

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

              Dates

              • Created:
                Updated:
                Resolved:

                Development