[
https://issues.apache.org/jira/browse/SAMZA-982?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xinyu Liu updated SAMZA-982:
----------------------------
Attachment: SAMZA-982.0.patch
> Add null check for offset update in OffsetManager
> -------------------------------------------------
>
> Key: SAMZA-982
> URL: https://issues.apache.org/jira/browse/SAMZA-982
> Project: Samza
> Issue Type: Bug
> Affects Versions: 0.11
> Reporter: Xinyu Liu
> Assignee: Xinyu Liu
> Priority: Blocker
> Attachments: SAMZA-982.0.patch
>
>
> During the process of making offsetManager thread-safe, I changed the impl of
> lastProcessedOffsets to use ConcurrentHashMap. However, I didn't realize
> offset can be null so it will trigger null pointer exception when
> ConcurrentHashMap.put(key, null). The fix will add the null check so null
> offset will be still supported such as in our hello-samza example.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
