Re: Samza task not receiving on one partition

2016-04-29 Thread Yi Pan
Hi, Jason, Sorry to hear that it caused you a long time to figure this out. Could you open a JIRA on this issue s.t. we can do some further investigation to see whether there is explicit indication from Kafka consumer on this problem and we can report correctly? -Yi On Fri, Apr 29, 2016 at 2:45

Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior

2016-04-29 Thread Jake Maes
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/46856/ --- (Updated April 29, 2016, 11:38 p.m.) Review request for samza, Boris Shkolnik,

Re: Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior

2016-04-29 Thread Jake Maes
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/46856/ --- (Updated April 29, 2016, 10:06 p.m.) Review request for samza, Boris Shkolnik,

Review Request 46856: SAMZA-943 Occasional test failure: TestStreamPartitionCountMonitor.testStartStopBehavior

2016-04-29 Thread Jake Maes
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/46856/ --- Review request for samza, Boris Shkolnik, Navina Ramesh, Jagadish Venkatraman, a

Re: Samza task not receiving on one partition

2016-04-29 Thread Jason Erickson
The issue was that there was a message that exceeded the default max.message.bytes for a kafka consumer. But rather than give any sort of error message, the thread responsible for consuming that partition would simply hang on that message. The other partition threads would continue along happily.

Re: Review Request 44920: SAMZA-680 Refactor the Samza AppMaster to support other cluster managers

2016-04-29 Thread Jagadish Venkatraman
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/44920/ --- (Updated April 29, 2016, 8:36 p.m.) Review request for samza, Boris Shkolnik, C

Re: Review Request 44920: SAMZA-680 Refactor the Samza AppMaster to support other cluster managers

2016-04-29 Thread Jagadish Venkatraman
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/44920/ --- (Updated April 29, 2016, 8:19 p.m.) Review request for samza, Boris Shkolnik, C

Review Request 46839: SAMZA-925: support for restart control message

2016-04-29 Thread Alex Buck
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/46839/ --- Review request for samza. Repository: samza Description --- SAMZA-925: s

Re: Review Request 46732: SAMZA-930 fix issue with json deserialisation in YarnUtil

2016-04-29 Thread Alex Buck
> On April 28, 2016, 5:28 p.m., Yi Pan (Data Infrastructure) wrote: > > Hi, @Alex, thanks for the quick update. There is a few more checkstyle > > failures: > > > > :samza-autoscaling_2.10:checkstyleTest > > [ant:checkstyle] > > /home/yipan/workspace/samza_master/samza-autoscaling/src/test/jav

Re: Review Request 46732: SAMZA-930 fix issue with json deserialisation in YarnUtil

2016-04-29 Thread Alex Buck
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/46732/ --- (Updated April 29, 2016, 11:13 a.m.) Review request for samza. Repository: sa