Flume
  1. Flume
  2. FLUME-1389

Flume gives opaque error if interceptor type not specified

    Details

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

      Description

      If you declare an interceptor in the configuration but you don't specify the type, flume-agent dies with an opaque NPE. Instead it should die with a message warning that the interceptor doesn't have a type. You can see this using the following config file:

      {{
      receiver1.sources = gen
      receiver1.sinks = null
      receiver1.channels = ch1

      receiver1.channels.ch1.type = memory

      receiver1.sources.gen.type = seq
      receiver1.sources.gen.channels = ch1

      receiver1.sinks.null.type = null
      receiver1.sinks.null.channel = ch1

      receiver1.sources.gen.interceptors = int_a
      }}

      Result is:
      {{
      12/07/22 17:34:11 ERROR properties.PropertiesFileConfigurationProvider: Failed to load configuration data. Exception follows.
      java.lang.NullPointerException
      at org.apache.flume.interceptor.InterceptorBuilderFactory.lookup(InterceptorBuilderFactory.java:31)
      at org.apache.flume.interceptor.InterceptorBuilderFactory.newInstance(InterceptorBuilderFactory.java:44)
      at org.apache.flume.channel.ChannelProcessor.configureInterceptors(ChannelProcessor.java:104)
      }}

        Activity

        Hide
        NO NAME added a comment -

        It looks like this type of validation is in place for sources/sinks already, we just need to add for interceptors.

        Show
        NO NAME added a comment - It looks like this type of validation is in place for sources/sinks already, we just need to add for interceptors.
        Hide
        Hari Shreedharan added a comment -

        Patch committed in commit 1c84ab3e4b1ed63d0578e1f439fba38a0b841d33. Thanks, Patrick!

        Show
        Hari Shreedharan added a comment - Patch committed in commit 1c84ab3e4b1ed63d0578e1f439fba38a0b841d33. Thanks, Patrick!

          People

          • Assignee:
            NO NAME
            Reporter:
            NO NAME
          • Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

            • Created:
              Updated:
              Resolved:

              Development