0

我是德鲁伊的新手。我已经使用Imply IAP 包设置了一个集群。使用Tranquility将事件从 Kafka 摄取到 Druid 中。我可以看到 Tranquility 正在接受这些事件 - 以下日志语句是我用来验证的：

2016-10-03 19:19:22,715 [KafkaConsumer-CommitThread] INFO  c.m.tranquility.kafka.KafkaConsumer - Flushed {conn_recs={receivedCount=1, sentCount=1, droppedCount=0, unparseableCount=0}} pending messages in 32056ms and committed offsets in 15ms.

但是，当我尝试在数据源上运行 timeBoundary 查询时，代理似乎遇到了异常。

以下是异常堆栈跟踪（从代理的日志中复制）：

java.nio.channels.UnresolvedAddressException
  at sun.nio.ch.Net.checkAddress(Net.java:101) ~[?:1.8.0_66]
  at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622) ~[?:1.8.0_66]
  at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.connect(NioClientSocketPipelineSink.java:108) [netty-3.10.4.Final.jar:?]
  at org.jboss.netty.channel.socket.nio.NioClientSocketPipelineSink.eventSunk(NioClientSocketPipelineSink.java:70) [netty-3.10.4.Final.jar:?]
  at org.jboss.netty.channel.DefaultChannelPipeline$DefaultChannelHandlerContext.sendDownstream(DefaultChannelPipeline.java:779) [netty-3.10.4.Final.jar:?]
  at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:54) [netty-3.10.4.Final.jar:?]

因为我不确定我需要查看哪些日志/进程来进一步调试，所以我一直被困在这一点上。

问题：有人可以解释我需要如何调试这样的问题 - 即我需要查看的任何特定日志等？

顺便说一句，我正在使用一个单独的 3 节点 zookeeper 集群和一个单节点 mysql 实例作为 druid 集群的外部依赖项。

如果我需要提供更多信息，请告诉我。

谢谢，吉廷

4

1 回答 1

0
  1. Tranquility 去 zookeeper 并获取霸主的 DNS 名称。
  2. Tranquility 尝试连接到霸主，然后你得到 UnresolvedAddressException。

您需要设置 DNS 或做一些事情才能通过主机名解析 IP 地址。

于 2016-11-09T15:25:23.137 回答