I think the Zookeeper watcher code should reside in task code. Haven't found guide on this subject so far.
Cheers On Sun, May 24, 2015 at 7:15 PM, [email protected] <[email protected]> wrote: > Can someone please help me on this? > > ------------------------------ > [email protected] > > > *发件人：* [email protected] > *发送时间：* 2015-05-24 13:53 > *收件人：* user <[email protected]> > *主题：* How to use zookeeper in Spark Streaming > > Hi， > In my spark streaming application, when the application starts and get > running, the Tasks running on the Worker nodes need to be notified that > some configurations have been changed from time to time, these > configurations reside on the Zookeeper. > > My question is, where should I put the code that works with Zookeeper for > the configuration change, in the Driver code or in the Task code? Is there > some guide on this? Thanks. > > > > > > ------------------------------ > [email protected] > >
