Re: Any way to monitor samza job?

2016-08-08 Thread 李斯宁
hi, David thanks for the information :) I will try On Mon, Aug 8, 2016 at 11:04 PM, David Yu wrote: > Samza has pretty good support for collectng metrics: > https://samza.apache.org/learn/documentation/0.10/container/metrics.html > > With these metrics logged in Kafka,

Re: Review Request 50619: SAMZA-963: add KV storage engine timers to help identify the issues on kv stores and also add unit test

2016-08-08 Thread Yi Pan (Data Infrastructure)
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/50619/#review145135 --- Ship it! Ship It! - Yi Pan (Data Infrastructure) On Aug. 5,

Re: State store changelog format

2016-08-08 Thread David Yu
That's great news. Will be keeping an eye on the release. On Mon, Aug 8, 2016 at 10:12 AM Jacob Maes wrote: > Hey David, > > I think that behavior is meant to prevent an issue on the Kafka 0.8 > Brokers. Samza 10.1 allows compression on log compacted topics, but

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

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

Re: State store changelog format

2016-08-08 Thread Jacob Maes
Hey David, I think that behavior is meant to prevent an issue on the Kafka 0.8 Brokers. Samza 10.1 allows compression on log compacted topics, but you'll need to make sure you're using Kafka 0.9 or higher on the Brokers. -Jake On Fri, Aug 5, 2016 at 10:57 PM, David Yu