[jira] [Created] (APEXCORE-326) Iteration causes problems when there are multiple streams between two operators

["Bhupesh Chawda (JIRA)" <ji...@apache.org>]

Bhupesh Chawda created APEXCORE-326:
---------------------------------------

             Summary: 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)