[
https://issues.apache.org/jira/browse/APEXCORE-326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207039#comment-15207039
]
ASF GitHub Bot commented on APEXCORE-326:
-----------------------------------------
GitHub user bhupeshchawda opened a pull request:
https://github.com/apache/incubator-apex-core/pull/282
APEXCORE-326: Bug fix. Added unit test.
Fixed validation in case of multiple streams between two operators.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/bhupeshchawda/incubator-apex-core
APEXCORE-326-iteration-bug
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-apex-core/pull/282.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #282
----
commit f0178e18a080e7411df2672bd7bd383c119a8923
Author: bhupesh <[email protected]>
Date: 2016-03-19T09:22:36Z
APEXCORE-326: Bug fix. Added unit test.
----
> Iteration causes problems when there are multiple streams between two
> operators
> -------------------------------------------------------------------------------
>
> Key: APEXCORE-326
> URL: https://issues.apache.org/jira/browse/APEXCORE-326
> Project: Apache Apex Core
> Issue Type: Bug
> Reporter: Bhupesh Chawda
> Assignee: David Yan
> Attachments: APEXCORE-326.patch
>
>
> Consider the following dag:
> {code:title=Application.java|borderStyle=solid}
> public void populateDAG(DAG dag, Configuration conf)
> {
> SampleInputOperator source = dag.addOperator("Source",
> SampleInputOperator.class);
> SampleOperator op1 = dag.addOperator("Op1", SampleOperator.class);
> SampleOperator op2 = dag.addOperator("Op2", SampleOperator.class);
> DefaultDelayOperator<Integer> delay = dag.addOperator("Delay",
> DefaultDelayOperator.class);
> dag.addStream("Source", source.output, op1.input1);
> dag.addStream("Stream1", op1.output1, op2.input1);
> dag.addStream("Stream2", op1.output2, op2.input2);
> dag.addStream("Op to Delay", op2.delayOutput, delay.input);
> dag.addStream("Delay to Op", delay.output, op1.input2);
> }
> {code}
> This causes the validation to fail causing "Loops in Dag" error message, even
> in the presence of delay operators.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
