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 2018/04/30 17:02:00 UTC

[jira] [Resolved] (SAMZA-1645) A few issues found by BEAM stress test

     [ https://issues.apache.org/jira/browse/SAMZA-1645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Xinyu Liu resolved SAMZA-1645.
------------------------------
    Resolution: Fixed

> A few issues found by BEAM stress test
> --------------------------------------
>
>                 Key: SAMZA-1645
>                 URL: https://issues.apache.org/jira/browse/SAMZA-1645
>             Project: Samza
>          Issue Type: Bug
>            Reporter: Xinyu Liu
>            Assignee: Xinyu Liu
>            Priority: Major
>             Fix For: 0.14.1
>
>
> # 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
(v7.6.3#76005)