[GitHub] samza pull request #494: SAMZA-1692: Standalone stability fixes.

GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/494 SAMZA-1692: Standalone stability fixes. * Currently on session expiration, processorListener with incorrect generationId is registered with zookeeper(ZkUtils generationId is incremented on reconn

[GitHub] samza pull request #493: SAMZA-1647: Fix NPE in onJobModelExpired handler in...

GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/493 SAMZA-1647: Fix NPE in onJobModelExpired handler in StreamProcessor. Changes * Switch from using volatile to AtomicReference in StreamProcessor. * Add sufficient guards where container fiel