Flume
  1. Flume
  2. FLUME-2238

Provide option to configure worker threads in NettyAvroRpcClient

    Details

    • Type: Bug Bug
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: v1.4.0
    • Fix Version/s: v1.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

      1. FLUME-2238.patch
        17 kB
        Cameron Gandevia

        Activity

        No work has yet been logged on this issue.

          People

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

            Dates

            • Created:
              Updated:
              Resolved:

              Development