[
https://issues.apache.org/jira/browse/FLUME-3021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15956396#comment-15956396
]
tycho_yang commented on FLUME-3021:
-----------------------------------
2017-04-05 14:36:17,839 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO -
org.apache.kafka.common.utils.AppInfoParser$AppInfo.<init>(AppInfoParser.java:82)]
Kafka version : 0.9.0.1
2017-04-05 14:36:17,839 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO -
org.apache.kafka.common.utils.AppInfoParser$AppInfo.<init>(AppInfoParser.java:83)]
Kafka commitId : 23c69d62a0cabf06
2017-04-05 14:36:17,842 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO -
org.apache.flume.channel.kafka.KafkaChannel.createConsumerAndRecords(KafkaChannel.java:296)]
Created new consumer to connect to Kafka
2017-04-05 14:36:32,230 (lifecycleSupervisor-1-0) [INFO -
org.apache.flume.source.kafka.SourceRebalanceListener.onPartitionsAssigned(KafkaSource.java:623)]
topic www-web - partition 2 assigned.
2017-04-05 14:36:32,230 (lifecycleSupervisor-1-0) [INFO -
org.apache.flume.source.kafka.SourceRebalanceListener.onPartitionsAssigned(KafkaSource.java:623)]
topic www-web - partition 0 assigned.
2017-04-05 14:36:32,230 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO -
org.apache.flume.channel.kafka.ChannelRebalanceListener.onPartitionsAssigned(KafkaChannel.java:751)]
topic www-web-ch-sink - partition 2 assigned.
2017-04-05 14:36:32,230 (lifecycleSupervisor-1-0) [INFO -
org.apache.flume.source.kafka.SourceRebalanceListener.onPartitionsAssigned(KafkaSource.java:623)]
topic www-web - partition 1 assigned.
2017-04-05 14:36:32,230 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO -
org.apache.flume.channel.kafka.ChannelRebalanceListener.onPartitionsAssigned(KafkaChannel.java:751)]
topic www-web-ch-sink - partition 1 assigned.
2017-04-05 14:36:32,231 (SinkRunner-PollingRunner-DefaultSinkProcessor) [INFO -
org.apache.flume.channel.kafka.ChannelRebalanceListener.onPartitionsAssigned(KafkaChannel.java:751)]
topic www-web-ch-sink - partition 0 assigned.
2017-04-05 14:36:32,242 (lifecycleSupervisor-1-0) [INFO -
org.apache.flume.source.kafka.KafkaSource.doStart(KafkaSource.java:520)] Kafka
source s1 started.
2017-04-05 14:36:32,242 (lifecycleSupervisor-1-0) [INFO -
org.apache.flume.instrumentation.MonitoredCounterGroup.register(MonitoredCounterGroup.java:119)]
Monitored counter group for type: SOURCE, name: s1: Successfully registered
new MBean.
2017-04-05 14:36:32,242 (lifecycleSupervisor-1-0) [INFO -
org.apache.flume.instrumentation.MonitoredCounterGroup.start(MonitoredCounterGroup.java:95)]
Component type: SOURCE, name: s1 started
2017-04-05 14:38:22,393 (PollableSourceRunner-KafkaSource-s1) [ERROR -
org.apache.flume.source.kafka.KafkaSource.doProcess(KafkaSource.java:314)]
KafkaSource EXCEPTION, {}
java.lang.IllegalStateException: value is absent
at com.google.common.base.Optional$Absent.get(Optional.java:263)
at
org.apache.flume.channel.kafka.KafkaChannel$KafkaTransaction.doRollback(KafkaChannel.java:584)
at
org.apache.flume.channel.BasicTransactionSemantics.rollback(BasicTransactionSemantics.java:168)
at
org.apache.flume.channel.ChannelProcessor.processEventBatch(ChannelProcessor.java:196)
at
org.apache.flume.source.kafka.KafkaSource.doProcess(KafkaSource.java:295)
at
org.apache.flume.source.AbstractPollableSource.process(AbstractPollableSource.java:60)
at
org.apache.flume.source.PollableSourceRunner$PollingRunner.run(PollableSourceRunner.java:133)
at java.lang.Thread.run(Thread.java:745)
2017-04-05 14:38:27,401 (PollableSourceRunner-KafkaSource-s1) [ERROR -
org.apache.flume.source.kafka.KafkaSource.doProcess(KafkaSource.java:314)]
KafkaSource EXCEPTION, {}
java.lang.IllegalStateException: value is absent
> flume Elasticsearch 5.0 not support
> -----------------------------------
>
> Key: FLUME-3021
> URL: https://issues.apache.org/jira/browse/FLUME-3021
> Project: Flume
> Issue Type: Bug
> Components: Sinks+Sources
> Affects Versions: 1.7.0
> Reporter: tycho_yang
> Assignee: Yonghao Zou
> Fix For: 1.8.0
>
> Attachments: FLUME-3021-0.patch
>
>
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
