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 field can be null.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/shanthoosh/samza
fix_npe_in_jobmodel_expired_handler
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/samza/pull/493.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #493
----
commit 41349d87d1f1396a17dc7b22fd9ae3444986978e
Author: Shanthoosh Venkataraman <svenkataraman@...>
Date: 2018-04-29T04:03:00Z
SAMZA-1647: Fix NPE in onJobModelExpired handler in StreamProcessor.
Changes
* Switch from using volatile to AtomicReference in StreamProcessor.
* Add sufficient guards where container field can be null.
NOTE: The classes in which these changes were made were aynonymous inner
classes,
so to add proper unit tests we need to do big haul of refactor.
----
---
