[ 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)