Review Request 41580: SAMZA-831: Update Samza 0.10 online documentation

2015-12-18 Thread Yi Pan (Data Infrastructure)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/41580/ --- Review request for samza, Chinmay Soman, Chris Riccomini, Jakob Homan, and Navin

Re: Review Request 41576: SAMZA-831: preparing 0.10.0 release candidate

2015-12-18 Thread Yi Pan (Data Infrastructure)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/41576/ --- (Updated Dec. 19, 2015, 1:24 a.m.) Review request for samza, Yan Fang, Chinmay

Re: Review Request 41576: SAMZA-831: preparing 0.10.0 release candidate

2015-12-18 Thread Yi Pan (Data Infrastructure)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/41576/ --- (Updated Dec. 19, 2015, 12:34 a.m.) Review request for samza, Yan Fang, Chinmay

Review Request 41576: SAMZA-831: preparing 0.10.0 release candidate

2015-12-18 Thread Yi Pan (Data Infrastructure)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/41576/ --- Review request for samza, Yan Fang, Chinmay Soman, Chris Riccomini, Jakob Homan,

CoordinatorStream errors

2015-12-18 Thread Rick Mangi
Hi all, I just started seeing these errors the other day. I am heavily refactoring my code, but it works locally. I’m wondering if anyone has seen this error when deploying to yarn. This is in stderr log on my application master. Exception in thread "AMRM Callback Handler Thread" org.apache.h

Re: KafkaSystemProducer partitioning

2015-12-18 Thread Michal Haris
Ah, that's unfortunate. Basically we have an existing stream-processing pipeline which relies on different partitioning schemes and we are writing some upstream Samza jobs. The only way to get it write in a particular partitioning scheme is then to write a different KafkaSystemFactory right ? Or pe

Replication Issue with Samza / Kafka

2015-12-18 Thread Louis Calisi
Hi: I’ve been a quite fan of Kafka / Samza for about a year now. The project I’ve been working for TripAdvisor is about to soft launch soon. Lately we’ve noticed replication error coming from Kafka (0.8.2.0). Samza is exclusively using this Kafka cluster, minus a small application that’s feedin

map async

2015-12-18 Thread Ivan.Antipin
Hello, Do you have any plans implementing map async for samza container ? This can be very useful and I suppose not very hard to implement...