[jira] [Created] (SAMZA-141) TaskInstance.offsets fails to update

["Chris Riccomini (JIRA)" <ji...@apache.org>]

Chris Riccomini created SAMZA-141:
-------------------------------------

             Summary: TaskInstance.offsets fails to update
                 Key: SAMZA-141
                 URL: https://issues.apache.org/jira/browse/SAMZA-141
             Project: Samza
          Issue Type: Bug
          Components: container
    Affects Versions: 0.6.0
            Reporter: Chris Riccomini
            Assignee: Chris Riccomini


TaskInstance has a variable called offsets, which manages offsets for each input stream. The variable is typed to SystemStream -> String. We use SystemString when intracting with it in all places, EXCEPT in the TaskInstance.process method, where we use a SystemStreamPartition as the key. This doesn't work, since a SystemStreamPartition and SystemStream with the same system and stream name are actually NOT equal, since the equality checks do a class check, and the classes don't match.

As a result, you end up with something like this:

{noformat}



--
This message was sent by Atlassian JIRA
(v6.1.5#6160)