Xinyu Liu created SAMZA-1645:

             Summary: A few issues found by BEAM stress test
                 Key: SAMZA-1645
             Project: Samza
          Issue Type: Bug
            Reporter: Xinyu Liu
            Assignee: Xinyu Liu

# Setting high priority on intermediate streams caused starvation on certain 
tasks. Due to the intermediate message kept coming, the input streams are not 
consumed and watermark messages are not generated, which makes downstream 
accumulates large state and makes processing slower thus make starvation worse.
 # Watermark broadcast needs to check whether the watermark is advanced.

This message was sent by Atlassian JIRA

Reply via email to