[jira] [Updated] (FLINK-12843) Refactor the pin logic in ReleaseOnConsumptionResultPartition

2019-06-17 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12843: --- Labels: pull-request-available (was: ) > Refactor the pin logic in ReleaseOnConsumptionResu

[jira] [Updated] (FLINK-12843) Refactor the pin logic in ReleaseOnConsumptionResultPartition

2019-06-17 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12843: - Description: The pin logic is for adding the reference counter based on number of subpartitions for {{R

[jira] [Updated] (FLINK-12843) Refactor the pin logic in ReleaseOnConsumptionResultPartition

2019-06-17 Thread zhijiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang updated FLINK-12843: - Summary: Refactor the pin logic in ReleaseOnConsumptionResultPartition (was: Refactor the pin logic in