You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "Bhupesh Chawda (JIRA)" <ji...@apache.org> on 2016/02/03 11:23:39 UTC
[jira] [Updated] (APEXCORE-326) Iteration causes problems when
there are multiple streams between two operators
[ https://issues.apache.org/jira/browse/APEXCORE-326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Bhupesh Chawda updated APEXCORE-326:
------------------------------------
Description:
Consider the following dag:
``` java
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);
}
```
This causes the validation to fail causing "Loops in Dag" error message, even in the presence of delay operators.
was:
Consider the following dag:
``` java
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);
}
```
This causes the validation to fail causing "Loops in Dag" error message, even in the presence of delay operators.
> 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
>
> Consider the following dag:
> ``` java
> 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);
> }
> ```
> 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)