You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@samza.apache.org by "Xinyu Liu (JIRA)" <ji...@apache.org> on 2016/07/29 00:09:20 UTC

[jira] [Created] (SAMZA-982) Add null check for offset update in OffsetManager

Xinyu Liu created SAMZA-982:
-------------------------------

             Summary: 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


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)