---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/41620/
---
(Updated Dec. 22, 2015, 1:04 a.m.)
Review request for samza, Yan Fang, Chinmay
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/41620/#review111564
---
Ship it!
lgtm!
- Navina Ramesh
On Dec. 22, 2015, 12:38 a.m., Yi
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/41620/
---
Review request for samza, Yan Fang, Chinmay Soman, Chris Riccomini, Jakob
Homan,
Ok. Sounds good. Thanks!
On Mon, Dec 21, 2015 at 11:38 AM, Rick Mangi wrote:
> HI Navina,
>
> It stopped happening once I deleted an old checkpoint topic. I think in
> the rapid development cycle my checkpoints became invalid. If it happens
> again I will save the logs.
>
> Thanks!
>
>
> > On De
HI Navina,
It stopped happening once I deleted an old checkpoint topic. I think in the
rapid development cycle my checkpoints became invalid. If it happens again I
will save the logs.
Thanks!
> On Dec 21, 2015, at 2:14 PM, Navina Ramesh
> wrote:
>
> Hi Rick,
> Can you share the entire log
Hi Rick,
Can you share the entire log for this issue? I suspect the concurrent
access happens on the bootstrappedSet (LinkedHashSet -> not thread safe)
between the Job Coordinator and SamzaAppMaster.
When a container fails, the AM tried to read the locality information. If
some other container req
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/41580/#review111516
---
Ship it!
Ship It!
- Navina Ramesh
On Dec. 19, 2015, 1:26 a.m.,
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/41576/#review111515
---
Ship it!
Ship It!
- Navina Ramesh
On Dec. 19, 2015, 1:24 a.m.,
Hi, Michal,
Yeah, unfortunately, based on the current code base, the only short term
solution would be your proposal.The issue is the following:
1. Kafka producer only applies the specified partition.class to the
ProducerRecord key. Samza allows the user to specify a partition key that
is differen
