Re: Review Request 48356: RFC: Samza as a library

2016-08-11 Thread Navina Ramesh
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/48356/ --- (Updated Aug. 12, 2016, 3:29 a.m.) Review request for samza, Chris Pettitt and

Re: Review Request 48356: RFC: Samza as a library

2016-08-11 Thread Navina Ramesh
> On July 15, 2016, 12:12 a.m., Yi Pan (Data Infrastructure) wrote: > > samza-core/src/main/java/org/apache/samza/configbuilder/ConfigBuilder.java, > > line 107 > > > > > > How would it work w/ RegexConfigRewriter?

Re: Question on changelog partition mapping

2016-08-11 Thread Yi Pan
Hi, Tommy, Which version of Samza are you using? Since 0.10, the changelog partition mapping has been moved to the coordinator stream, not in the checkpoint topic any more. That said, I want to ask a few more questions to understand what you referred to as "non-deterministic" behavior. So, betwee

Question on changelog partition mapping

2016-08-11 Thread Tommy Becker
We recently had an issue that caused us to lose the contents of one of our Samza job's checkpoint topics. We were not that concerned about losing the checkpointed offsets and so we restarted the job. We then started seeing some very strange results and were able to trace it back to the fact tha

Re: Review Request 47835: SAMZA-914: Initial draft for Java programming APIs on operators supporting DAGs

2016-08-11 Thread Yi Pan (Data Infrastructure)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/47835/ --- (Updated Aug. 11, 2016, 6:50 p.m.) Review request for samza, Boris Shkolnik, Ch