Github user marmbrus commented on a diff in the pull request:
    --- Diff: 
    @@ -72,13 +74,17 @@ class StreamExecution(
        * Tracks how much data we have processed and committed to the sink or 
state store from each
        * input source.
    +   * Only the scheduler thread should modify this field, and only in 
atomic steps. Other threads
    +   * must create a local copy before iterating over this data structure.
    --- End diff --
    I agree with the first sentance.  I'm not sure I understand the second.

If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at or file a JIRA ticket
with INFRA.

To unsubscribe, e-mail:
For additional commands, e-mail:

Reply via email to