[
https://issues.apache.org/jira/browse/SPARK-12775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15096550#comment-15096550
]
Cody Koeninger commented on SPARK-12775:
----------------------------------------
Couldn't find leader offsets ... because you couldn't resolve the leader
hostname... doesn't seem that misleading to me.
If you want to be able to improve the error message, can you post the full
stacktrace?
> Couldn't find leader offsets exception when hostname can't be resolved
> ----------------------------------------------------------------------
>
> Key: SPARK-12775
> URL: https://issues.apache.org/jira/browse/SPARK-12775
> Project: Spark
> Issue Type: Bug
> Components: Streaming
> Affects Versions: 1.6.0
> Reporter: Sebastian Piu
> Priority: Minor
>
> When hostname resolution fails for a broker an unclear/misleading error is
> shown:
> org.apache.spark.SparkException: java.nio.channels.ClosedChannelException
> org.apache.spark.SparkException: Couldn't find leader offsets for
> Set([mytopic,0], [mytopic,18], [mytopic,12], [mytopic,6])
> at
> org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply(KafkaCluster.scala:366)
> at
> org.apache.spark.streaming.kafka.KafkaCluster$$anonfun$checkErrors$1.apply(KafkaCluster.scala:366)
> Error above ocurred when a broker was added to the cluster and my machine
> could not resolve its hostname
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
