Does Samza work with ResourceManager in HA?

2015-11-03 Thread John Tipper
Does anyone have Samza working with resource manager in HA? If so, what do I set yarn.resourcemanager.hostname to in yarn-site.xml? Can anyone share a working yarn-site.xml please? If I set it to the first of my RMs, the the job submission works ok if I submit the job from that RM and the R

Re: Does Samza work with ResourceManager in HA?

2015-11-03 Thread John Tipper
yarn.resourcemanager.recovery.enabled true yarn.resourcemanager.zk-state-store.parent-path /yarn_ops02_rmstore > On Nov 3, 2015, at 6:10 AM, John Tipper wrote: > > > > Does anyone have Samza working with resource manager in HA? If so, what do I > set yarn.resourcemanager.hostname to in y

Does Samza create partitions automatically when sending messages?

2015-11-03 Thread John Tipper
If you use Samza's OutgoingMessageEnvelope to send a message using this format: public OutgoingMessageEnvelope(SystemStream systemStream, java.lang.O

Does Samza work with ResourceManager in HA?

2015-11-03 Thread John Tipper
Does anyone have Samza working with resource manager in HA? If so, what do I set yarn.resourcemanager.hostname to in yarn-site.xml? Can anyone share a working yarn-site.xml please? If I set it to the first of my RMs, the the job submission works ok if I submit the job from that RM and the RM