Uploaded image for project: 'Kylin'
  1. Kylin
  2. KYLIN-1696

Haven't caught exception when connection issue occurs for some Broker

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: v1.4.0, v1.5.0
    • Fix Version/s: None
    • Component/s: NRT Streaming
    • Labels:
      None

      Description

      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)

        Attachments

          Activity

            People

            • Assignee:
              yaho Zhong Yanghong
              Reporter:
              yaho Zhong Yanghong
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: