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

Can't get WAL to work on Windows. NULL pointer exception in ThriftEventAdaptor.set when using WAL configuration.

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Won't Fix
    • Affects Version/s: 0.9.3
    • Fix Version/s: 0.9.5
    • Component/s: Shell, Sinks+Sources
    • Labels:
    • Environment:

      Windows

      Description

      Can't get WAL to work on Windows. NULL pointer exception in ThriftEventAdaptor.set when using WAL configuration.

      11/06/09 05:36:11 ERROR connector.DirectDriver: Driving src/sink failed! LazyOpenSource | LazyOpenDecorator because null
      java.lang.NullPointerException
      at com.cloudera.flume.handlers.thrift.ThriftEventAdaptor.set(ThriftEventAdaptor.java:183)
      at com.cloudera.flume.handlers.rolling.RollSink.append(RollSink.java:172)
      at com.cloudera.flume.agent.durability.NaiveFileWALDeco.append(NaiveFileWALDeco.java:138)
      at com.cloudera.flume.agent.AgentSink.append(AgentSink.java:112)
      at com.cloudera.flume.core.EventSinkDecorator.append(EventSinkDecorator.java:60)
      at com.cloudera.flume.handlers.debug.LazyOpenDecorator.append(LazyOpenDecorator.java:75)
      at com.cloudera.flume.core.connector.DirectDriver$PumperThread.run(DirectDriver.java:93)

      One agent, one collector configuration as follows. Agent is running on a Windows box (running 0.9.3) Collector on a Linux VM (running 0.9.3).

      agent.et.local : rpcSource( 54001 ) | agentSink("collector.et.local",35853)
      collector : collectorSource(35853) | collectorSink("/var/log/collected","collected")

      Agent Config

      <property>
      <name>flume.collector.event.host</name>
      <value>collector.et.local</value>
      </property>

      <property>
      <name>flume.collector.port</name>
      <value>35853</value>
      </property>

      Collector Config

      <property>
      <name>flume.collector.event.host</name>
      <value>localhost</value>
      </property>

      <property>
      <name>flume.collector.port</name>
      <value>35853</value>
      </property>

      Full log attached.

      I am able to get best effort sink on agent to work. i.e.

      agentBESink("collector.et.local",35853)

        Attachments

        1. ASF.LICENSE.NOT.GRANTED--flumenode-stderr.txt
          15 kB
          Disabled imported user

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              flume_jseiler@exacttarget.com Disabled imported user
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: