Загрузка плагина Apache Avro для Tranquility завершается неудачно с исключением - PullRequest
Новая
       10

Загрузка плагина Apache Avro для Tranquility завершается неудачно с исключением

0 голосов
/ 08 июня 2018

Для производителя Kafka Avro я запускаю: 

./kafka-avro-console-producer --broker-list localhost:9092 --topic pageviews --property value.schema='{"type":"record","name":"mypageviews","fields":[{"name":"time","type":"string"},{"name":"url","type":"string"},{"name":"user","type":"string"},{"name":"latencyMs","type":"int"}]}'

{"time": "2018-05-31T14:23:11Z", "url": "/foo/bar", "user": "alice", "latencyMs": 32}

Для Tranquility Kafka я запускаю: 

bin/tranquility kafka -configFile ../druid-0.12.1/conf-quickstart/tranquility/avro.json

Вот часть синтаксического анализатора соответствующей avro.json: 

"parser" : {
        "type" : "avro_stream",
        "avroBytesDecoder" : {
          "type" : "schema_inline",
          "schema"  : {
            "namespace": "SKY",
            "name": "mypageviews",
            "type": "record",
            "fields": [
              { "name": "time", "type": "string" },
              { "name": "url", "type": "string" },
              { "name": "user", "type": "string" },
              { "name": "latencyMs", "type": "int" }
            ]
          }
        },

        "parseSpec" : {

          "timestampSpec" : {
            "column" : "time",
            "format" : "auto"
          },
          "dimensionsSpec" : {
            "dimensions" : ["url", "user"],
            "dimensionExclusions" : [
              "timestamp",
              "value"
            ]
          },
          "format" : "avro"

        }
      }

Вот ошибка, которую я получаю:

ОШИБКА cmtranquility.kafka.KafkaConsumer - Исключение: java.lang.AbstractMethodError: io.druid.data.input.AvroStreamInputRowParser.arse ()./ lang / Object;) Lio / druid / data / input / InputRow;

...