[jira] [Updated] (GEARPUMP-78) Support DAG with loops
[ https://issues.apache.org/jira/browse/GEARPUMP-78?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kam Kasravi updated GEARPUMP-78: Assignee: Manu Zhang > Support DAG with loops > -- > > Key: GEARPUMP-78 > URL: https://issues.apache.org/jira/browse/GEARPUMP-78 > Project: Apache Gearpump > Issue Type: Improvement > Components: streaming >Reporter: Manu Zhang >Assignee: Manu Zhang > > imported from [https://github.com/gearpump/gearpump/issues/1231] on behalf of > [~clockfly], > DAG with loop should not be called DAG :) > We see use cases that require a feedback channel. > The challengues will be: > # how to support the low watermark clock? As the clock is defined recursively? > # How to support back-pressure. DAG with loop can possiblely create a > live-lock issue. With each processor wait for acks from other processor > before sending acks. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (GEARPUMP-78) Support DAG with loops
[ https://issues.apache.org/jira/browse/GEARPUMP-78?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manu Zhang updated GEARPUMP-78: --- Summary: Support DAG with loops (was: https://github.com/gearpump/gearpump/issues/1231) > Support DAG with loops > -- > > Key: GEARPUMP-78 > URL: https://issues.apache.org/jira/browse/GEARPUMP-78 > Project: Apache Gearpump > Issue Type: Improvement > Components: streaming >Reporter: Manu Zhang > > imported from [https://github.com/gearpump/gearpump/issues/1231] on behalf of > [~clockfly], > DAG with loop should not be called DAG :) > We see use cases that require a feedback channel. > The challengues will be: > # how to support the low watermark clock? As the clock is defined recursively? > # How to support back-pressure. DAG with loop can possiblely create a > live-lock issue. With each processor wait for acks from other processor > before sending acks. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
