apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bhupesh Chawda (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (APEXCORE-326) Iteration causes problems when there are multiple streams between two operators
Date Wed, 03 Feb 2016 10:26:39 GMT

     [ 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:

{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.


  was:
Consider the following dag:

{code:title=Bar.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.



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

Mime
View raw message