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

Provide option to configure worker threads in NettyAvroRpcClient

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.4.0
    • Fix Version/s: 1.5.0
    • Component/s: Sinks+Sources
    • Labels:
      None

      Description

      From dev ML, Credits to Cameron Gandevia

      Embedded flume agents were using around 50 netty IO worker threads.

      The issue was tracked down to the NettyAvroRpcClient which instantiates
      the NioClientSocketChannelFactory with the default workerCount (2 * the
      number of available processors). We would like finer control over the
      number of IO threads we dedicate to flume

        Attachments

        1. FLUME-2238.patch
          17 kB
          Cameron Gandevia

          Activity

            People

            • Assignee:
              gnoremac Cameron Gandevia
              Reporter:
              paliwalashish Ashish Paliwal
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: