s"${topicDirs.consumerOffsetDir}/${osr.partition}"
> ZkUtils.updatePersistentPath(zkClient, zkPath,
> osr.untilOffset.toString)
> }
> }
>
> Why would there be serialization issues when I'm not trying to pass
> ZkClient
> to any of the workers?
>
ls.updatePersistentPath(zkClient, zkPath,
osr.untilOffset.toString)
}
}
Why would there be serialization issues when I'm not trying to pass ZkClient
to any of the workers?
Thanks
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Direct-Streami
itoring purposes, that should be fine.
>
>
> On Mon, Aug 24, 2015 at 12:11 PM, suchenzang wrote:
>
>> Forgot to include the PR I was referencing:
>> https://github.com/apache/spark/pull/4805/
>>
>>
>>
>> --
>> View this message in context:
&g
lude the PR I was referencing:
> https://github.com/apache/spark/pull/4805/
>
>
>
> --
> View this message in context:
> http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Direct-Streaming-With-ZK-Updates-tp24423p24424.html
> Sent from the Apache Spark User Li
Forgot to include the PR I was referencing:
https://github.com/apache/spark/pull/4805/
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Direct-Streaming-With-ZK-Updates-tp24423p24424.html
Sent from the Apache Spark User List mailing list archive at
missing something about
ZK here, please let me know too.
--
View this message in context:
http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Direct-Streaming-With-ZK-Updates-tp24423.html
Sent from the Apache Spark User
