0

我正在尝试从 avro 源读取 json 并接收到 Solr。当我尝试readLine {}并存储为字符串时，它起作用了。但是当尝试readJson{}它抛出以下错误时。

版本：CDH 5.9.0，包裹

错误

2017-01-26 06:35:38,604 ERROR org.apache.flume.lifecycle.LifecycleSupervisor: Unable to start SinkRunner: { policy:org.apache.flume.sink.DefaultSinkProcessor@513a4842 counterGroup:{ name:null counters:{} } } - Exception follows.
java.lang.NoSuchFieldError: USE_DEFAULTS
        at com.fasterxml.jackson.annotation.JsonInclude$Value.<clinit>(JsonInclude.java:204)
        at com.fasterxml.jackson.databind.cfg.MapperConfig.<clinit>(MapperConfig.java:44)
        at com.fasterxml.jackson.databind.ObjectMapper.<init>(ObjectMapper.java:558)
        at com.fasterxml.jackson.databind.ObjectMapper.<init>(ObjectMapper.java:483)
        at org.kitesdk.morphline.json.ReadJsonBuilder$ReadJson.<init>(ReadJsonBuilder.java:88)
        at org.kitesdk.morphline.json.ReadJsonBuilder.build(ReadJsonBuilder.java:55)
        at org.kitesdk.morphline.base.AbstractCommand.buildCommand(AbstractCommand.java:307)
        at org.kitesdk.morphline.base.AbstractCommand.buildCommandChain(AbstractCommand.java:254)
        at org.kitesdk.morphline.stdlib.Pipe.<init>(Pipe.java:46)
        at org.kitesdk.morphline.stdlib.PipeBuilder.build(PipeBuilder.java:40)
        at org.kitesdk.morphline.base.Compiler.compile(Compiler.java:126)
        at org.kitesdk.morphline.base.Compiler.compile(Compiler.java:55)
        at org.apache.flume.sink.solr.morphline.MorphlineHandlerImpl.configure(MorphlineHandlerImpl.java:101)
        at org.apache.flume.sink.solr.morphline.MorphlineSink.start(MorphlineSink.java:98)
        at org.apache.flume.sink.DefaultSinkProcessor.start(DefaultSinkProcessor.java:46)
        at org.apache.flume.SinkRunner.start(SinkRunner.java:79)
        at org.apache.flume.lifecycle.LifecycleSupervisor$MonitorRunnable.run(LifecycleSupervisor.java:251)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
        at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)

水槽配置：

agent.sources = AvroSource
agent.channels = memorychannel1
agent.sinks = solrSink

agent.channels.memorychannel1.type = memory
agent.channels.memorychannel1.capacity = 10000
agent.channels.memorychannel1.transactionCapacity = 200

The avro source
agent.sources.AvroSource.type     = avro
agent.sources.AvroSource.bind     = 0.0.0.0
agent.sources.AvroSource.port     = 4344
agent.sources.AvroSource.channels = memorychannel1
agent.sources.AvroSource.compression-type = deflate

agent.sinks.solrSink.type = org.apache.flume.sink.solr.morphline.MorphlineSolrSink
agent.sinks.solrSink.morphlineFile = /home/flume/morphline.conf

agent.sources.AvroSource.channels = memorychannel1
agent.sinks.solrSink.channel = memorychannel1

吗啉配置文件

SOLR_LOCATOR：{集合：testCollection zkHost：“192.168.21.31:2181/solr”}

morphlines : [ { id : morphline1 importCommands : ["com.cloudera. ", "org.apache.solr. ", "org.kitesdk.**"]

commands : [
    # read the JSON blob
  {  readJson: {}  }
  {
    extractAvroPaths {
      flatten : false
      paths : {
        id : /id
        type : /type
        name : /name
        address : /address
      }
    }
  }

  {
    sanitizeUnknownSolrFields {
      # Location from which to fetch Solr schema
      solrLocator : ${SOLR_LOCATOR}

      # renameToPrefix : "ignored_"
    }
  }

  # load the record into a Solr server or MapReduce Reducer.
  {
    loadSolr {
      solrLocator : ${SOLR_LOCATOR}
    }
  }
 ]   } ]
4

1 回答 1

0

此错误来自 jackson-annotations 库。

USE_DEFAULTS 枚举常量是在 2.6 中添加的， jackson-annotation 文档的屏幕截图 并且 CDH 5.9.0 具有旧版本的 jackson-annotations。
CDH jar 列表 添加新版本以解决问题。

于 2017-02-20T09:27:40.967 回答