Linking two flows in cascading

[Srinivas Pachari]

Hello all,

I am trying to link two cascade flows such that one's output should be inout to the other.

My first flow definition is like this

FlowDef flowDef1 = FlowDef.flowDef().setName("firstflow")

            .addSource(pipe1, sourceTap)

            .addSource(pipe2, targetTap)

            .addTailSink(outputPipe1, targetTap1);

FlowConnector flowconnector1 = new LocalFlowConnector();

Flow flow1 = flowconnector1.connect(flowDef1);

FlowDef flowDef2 = FlowDef.flowDef().setName("secondflow")

            .addSource(outputPipe1, targetTap1)

            .addTailSink(outputPipe2, targetPipe2);

FlowConnector flowconnector2 = new LocalFlowConnector();

Flow flow2 = flowconnector2.connect(flowDef1);

CascadeConnector connector = new CascadeConnector();

Cascade cascade = connector.connect(flow2, flow1);

When I run this it says pipe has too many heads [pipe1, pipe2]. Any help would be appreciated. 

[Chris K Wensel]

it would be helpful to know the Cascading version, the actual stacktrace, and best of all, a reproducible test case.

you might also write out the dot files for each flow and see if what you are attempting to do is reasonable.

ckw

--
You received this message because you are subscribed to the Google Groups "cascading-user" group.
To unsubscribe from this group and stop receiving emails from it, send an email to cascading-use...@googlegroups.com.
To post to this group, send email to cascadi...@googlegroups.com.
Visit this group at https://groups.google.com/group/cascading-user.
To view this discussion on the web visit https://groups.google.com/d/msgid/cascading-user/b29b1224-09bd-4363-b9d0-5484e2845517%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.

—

Chris K Wensel

415-203-5022

ch...@wensel.net

https://www.linkedin.com/in/cwensel