Re: Review Request 49877: SAMZA-972: Holistic memory monitoring for SamzaContainer

2016-07-18 Thread Jagadish Venkatraman
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/49877/ --- (Updated July 19, 2016, 6:48 a.m.) Review request for samza, Boris Shkolnik, Ch

Re: Review Request 49877: SAMZA-972: Holistic memory monitoring for SamzaContainer

2016-07-18 Thread Jagadish Venkatraman
> On July 15, 2016, 9:34 p.m., Yi Pan (Data Infrastructure) wrote: > > samza-core/src/main/java/org/apache/samza/container/host/ProcfsBasedStatisticsGetter.java, > > line 34 > > > > > > Just curious, if the default i

Review Request 50174: SAMZA-977: User doc for samza multithreading

2016-07-18 Thread Xinyu Liu
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50174/ --- Review request for samza, Chris Pettitt, Navina Ramesh, and Yi Pan (Data Infrast

ApacheCon: Getting the word out internally

2016-07-18 Thread Melissa Warnkin
ApacheCon: Getting the word out internally Dear Apache Enthusiast, As you are no doubt already aware, we will be holding ApacheCon in Seville, Spain, the week of November 14th, 2016. The call for papers (CFP) for this event is now open, and will remain open until September 9th. The event is divid

Re: Review Request 50143: Support the notion of 'end-of-stream' in Samza when consuming from finite sources

2016-07-18 Thread Jagadish Venkatraman
> On July 18, 2016, 5:12 p.m., Xinyu Liu wrote: > > samza-api/src/main/java/org/apache/samza/task/EndOfStreamListenerTask.java, > > line 16 > > > > > > Is it always true that user will need to commit before shutting

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

2016-07-18 Thread Chris Pettitt
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/47835/#review142421 --- The description says this is the initial draft implementation, but

Re: Review Request 50151: SAMZA-975 Initial Samza REST Implementation

2016-07-18 Thread Jake Maes
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50151/ --- (Updated July 18, 2016, 7:30 p.m.) Review request for samza, Boris Shkolnik, Ch

Review Request 50154: SAMZA-976 Samza REST Documentation

2016-07-18 Thread Jake Maes
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50154/ --- Review request for samza, Boris Shkolnik, Chris Pettitt, Jake Maes, Navina Rames

Review Request 50151: SAMZA-975 Initial Samza REST Implementation

2016-07-18 Thread Jake Maes
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50151/ --- Review request for samza, Boris Shkolnik, Chris Pettitt, Jake Maes, Navina Rames

Re: Review Request 50056: SAMZA-863: Multithreading changes

2016-07-18 Thread Xinyu Liu
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50056/ --- (Updated July 18, 2016, 6:15 p.m.) Review request for samza, Chris Pettitt, Nav

Re: Review Request 50056: SAMZA-863: Multithreading changes

2016-07-18 Thread Xinyu Liu
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50056/ --- (Updated July 18, 2016, 6:14 p.m.) Review request for samza, Chris Pettitt, Nav

Re: Review Request 50056: Multithreading changes

2016-07-18 Thread Xinyu Liu
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50056/ --- (Updated July 18, 2016, 6:13 p.m.) Review request for samza, Chris Pettitt, Nav

Re: Review Request 50143: Support the notion of 'end-of-stream' in Samza when consuming from finite sources

2016-07-18 Thread Xinyu Liu
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50143/#review142580 --- samza-api/src/main/java/org/apache/samza/task/EndOfStreamListener

Review Request 50143: Support the notion of 'end-of-stream' in Samza when consuming from finite sources

2016-07-18 Thread Jagadish Venkatraman
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50143/ --- Review request for samza, Boris Shkolnik, Chris Pettitt, Fred Ji, Jake Maes, Yi

Re: Review Request 50082: SAMZA-973: Disk Quotas: clamp max delay, better measure processing time

2016-07-18 Thread Chris Pettitt
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50082/ --- (Updated July 18, 2016, 3:29 p.m.) Review request for samza. Repository: samz

Re: Review Request 50082: SAMZA-973: Disk Quotas: clamp max delay, better measure processing time

2016-07-18 Thread Chris Pettitt
> On July 15, 2016, 10:52 p.m., Xinyu Liu wrote: > > samza-core/src/main/scala/org/apache/samza/container/RunLoop.scala, line 80 > > > > > > Shall we move this line in the process() function? I'll move it into proces