You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@kylin.apache.org by "Zhong Yanghong (JIRA)" <ji...@apache.org> on 2016/05/16 04:42:12 UTC
[jira] [Commented] (KYLIN-1696) Have caught exception when
connection issue occurs for some Broker
[ https://issues.apache.org/jira/browse/KYLIN-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15284142#comment-15284142 ]
Zhong Yanghong commented on KYLIN-1696:
---------------------------------------
To get the leader broker, every broker in the cluster needs to be visited. However, exceptions have been caught for those brokers with issues.
> Have caught exception when connection issue occurs for some Broker
> ------------------------------------------------------------------
>
> Key: KYLIN-1696
> URL: https://issues.apache.org/jira/browse/KYLIN-1696
> Project: Kylin
> Issue Type: Bug
> Components: streaming
> Affects Versions: v1.5.0, v1.4.0
> Reporter: Zhong Yanghong
> Assignee: Zhong Yanghong
>
> 2016-05-16 01:50:24,711 ERROR [main StreamingCLI:109]: error start streaming
> java.lang.RuntimeException: error when get StreamingMessages
> at org.apache.kylin.source.kafka.KafkaStreamingInput.getBatchWithTimeWindow(KafkaStreamingInput.java:93)
> at org.apache.kylin.engine.streaming.OneOffStreamingBuilder$1.run(OneOffStreamingBuilder.java:72)
> at org.apache.kylin.engine.streaming.cli.StreamingCLI.startOneOffCubeStreaming(StreamingCLI.java:129)
> at org.apache.kylin.engine.streaming.cli.StreamingCLI.main(StreamingCLI.java:103)
> Caused by: java.nio.channels.UnresolvedAddressException
> at sun.nio.ch.Net.checkAddress(Net.java:127)
> at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:644)
> at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
> at kafka.consumer.SimpleConsumer.connect(SimpleConsumer.scala:44)
> at kafka.consumer.SimpleConsumer.getOrMakeConnection(SimpleConsumer.scala:142)
> at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:69)
> at kafka.consumer.SimpleConsumer.send(SimpleConsumer.scala:93)
> at kafka.javaapi.consumer.SimpleConsumer.send(SimpleConsumer.scala:68)
> at org.apache.kylin.source.kafka.util.KafkaRequester.getPartitionMetadata(KafkaRequester.java:132)
> at org.apache.kylin.source.kafka.util.KafkaUtils.getLeadBroker(KafkaUtils.java:53)
> at org.apache.kylin.source.kafka.util.KafkaUtils.getFirstAndLastOffset(KafkaUtils.java:113)
> at org.apache.kylin.source.kafka.util.KafkaUtils.findClosestOffsetWithDataTimestamp(KafkaUtils.java:102)
> at org.apache.kylin.source.kafka.KafkaStreamingInput$StreamingMessageProducer.call(KafkaStreamingInput.java:141)
> at org.apache.kylin.source.kafka.KafkaStreamingInput$StreamingMessageProducer.call(KafkaStreamingInput.java:104)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)