我是 Druid 的新手。我已经使用 Imply IAP package 设置了一个集群。 使用 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 集群的外部依赖项。
如果我需要提供更多信息，请告诉我。
谢谢， 吉辛
最佳答案
- Tranquility 转到 Zookeeper 并获取霸主的 DNS 名称。
- Tranquility 尝试连接到霸主，然后您收到 UnresolvedAddressException。
您需要设置 DNS 或执行某些操作才能通过主机名解析 IP 地址。
关于java - Druid 经纪人遇到 UnresolvedAddressException，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/39840594/