Re: Review Request 50154: SAMZA-976 Samza REST Documentation

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50154/#review143649 --- bin/generate-javadocs.sh (line 22)

Re: Review Request 50154: SAMZA-976 Samza REST Documentation

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50154/ --- (Updated July 27, 2016, 12:28 a.m.) Review request for samza, Boris Shkolnik, C

Re: Review Request 50451: SAMZA-981: Set consistent Kafka clientId for a job instance

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50451/ --- (Updated July 26, 2016, 11:46 p.m.) Review request for samza, Navina Ramesh and

Re: Review Request 50451: SAMZA-981: Set consistent Kafka clientId for a job instance

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50451/ --- (Updated July 26, 2016, 11:44 p.m.) Review request for samza, Navina Ramesh and

Re: Review Request 50318: SAMZA-979: Remove KafkaCheckpointMigration

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50318/#review143632 --- Ship it! Are we sure that noone will try to upgraded from a ver

Re: SamzaSQL document required

+Yi Yi, Can you please point Ankita to the SQL related documents? I think you have the most context here. On Tue, Jul 26, 2016 at 11:19 AM, Ankita Karandikar < akarandi...@maprtech.com> wrote: > Hi, > > Can you please reply on this? > > Thank you. > > Regards, > Ankita > > On Thu, Jul 21, 2016 a

Re: Sync Kafka producer by default?

I'm using 0.10. Thanks for confirming. On Tue, Jul 26, 2016 at 1:12 PM Navina Ramesh wrote: > Hi David, > Which version of Samza are you using? Starting with Samza 0.8, I think we > always used async producer. > > Thanks! > Navina > > On Tue, Jul 26, 2016 at 10:38 AM, David Yu > wrote: > > > O

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

> On July 15, 2016, 12:12 a.m., Yi Pan (Data Infrastructure) wrote: > > samza-core/src/main/java/org/apache/samza/standalone/StandaloneJobCoordinator.java, > > line 70 > > > > > > I don't fully understand the "unfort

Re: SamzaSQL document required

Hi, Can you please reply on this? Thank you. Regards, Ankita On Thu, Jul 21, 2016 at 10:16 AM, Ankita Karandikar < akarandi...@maprtech.com> wrote: > Hi, > > I wanted to try out SamzaSQL, but I could not find any document available > for it on the website. > Could you please send me any docume

Re: Review Request 50451: SAMZA-981: Set consistent Kafka clientId for a job instance

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50451/#review143591 --- Fix it, then Ship it! lgtm! samza-kafka/src/test/scala/org/ap

Re: Review Request 50451: SAMZA-981: Set consistent Kafka clientId for a job instance

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50451/ --- (Updated July 26, 2016, 6:15 p.m.) Review request for samza, Navina Ramesh and

Review Request 50451: SAMZA-981: Set consistent Kafka clientId for a job instance

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50451/ --- Review request for samza, Navina Ramesh and Yi Pan (Data Infrastructure). Repos

Re: Sync Kafka producer by default?

Hi David, Which version of Samza are you using? Starting with Samza 0.8, I think we always used async producer. Thanks! Navina On Tue, Jul 26, 2016 at 10:38 AM, David Yu wrote: > Our session-roll-up Samza job is experience throughput issues. We would > like to fine-tune our Kafka producer. Does

Sync Kafka producer by default?

Our session-roll-up Samza job is experience throughput issues. We would like to fine-tune our Kafka producer. Does Samza use "producer.type=sync" by default? From the JMX console, I'm seeing some producer batching metrics. I thought those are for async producers. Thanks, David

Re: Review Request 50318: SAMZA-979: Remove KafkaCheckpointMigration

> On July 25, 2016, 11:19 p.m., Navina Ramesh wrote: > > samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala, > > line 226 > > > > > > This info looks pretty useful. Any particular reason you a

Re: Review Request 50318: SAMZA-979: Remove KafkaCheckpointMigration

> On July 25, 2016, 11:19 p.m., Navina Ramesh wrote: > > samza-core/src/main/scala/org/apache/samza/checkpoint/OffsetManager.scala, > > line 226 > > > > > > This info looks pretty useful. Any particular reason you a