[GitHub] samza pull request #344: SAMZA-1474: Bump up rocksdb version to 5.7.3 to inc...

2017-10-30 Thread bharathkk
GitHub user bharathkk opened a pull request: https://github.com/apache/samza/pull/344 SAMZA-1474: Bump up rocksdb version to 5.7.3 to include licensing changes You can find more details on the bug fixes and API changes [here](https://github.com/facebook/rocksdb/releases). I upgraded

Samza questions (downtime during deployment and num partition per task)

2017-10-30 Thread Tony Du
Hi, we're looking into Samza for doing real-time processing. We have couple questions w.r.t Samza functionality 1. One "must-have" requirement for us is zero/minimal downtime during deployment of Samza jobs. One approach that we're thinking of is to start a new instance of the same Samza job and m

Exit code 248 from YARN and InterruptedException

2017-10-30 Thread XiaoChuan Yu
Hi, I'm trying to debug some problem with a Samza job that loads data from a Cassandra database into Kafka via a custom System implementation. The System makes use of BlockingEnvelopeMap. What I see in the logs is InterruptedException from put calls from the class that inherited BlockingEnvelopeM