Re: Connect 2 datastreams and iterate

[Biplob Biswas]

Hi Ufuk,

I get the error before running it. I mean somehow the syntax is also not
right.
I am trying to do the following:

                ConnectedStreams<Long[], Long> connectedStream = 
br.connect(mainInput);
        
                IterativeStream.ConnectedIterativeStreams<Long[], Long, Long[]> 
iteration
=
                        
connectedStream.iterate().withFeedbackType(Long[].class);

and i am getting an error at the iterate() method, it says the following:
                "The method iterate() is undefined for the type
ConnectedStreams<Long[],Long>"
and also,

"Incorrect number of arguments for type
IterativeStream.ConnectedIterativeStreams; it cannot be parameterized with
arguments <Long[], Long, Long[]>"

What a I doing wrong here?

Thanks and Regards
Biplob Biswas



Ufuk Celebi wrote
> Please provide the error message and stack trace in order to help
> investigating this further.
> 
> On Thu, May 19, 2016 at 7:17 PM, Biplob Biswas &lt;

> revolutionisme@

> &gt; wrote:
>> Hi,
>>
>> Is there a way to connect 2 datastreams and iterate and then get the
>> feedback as a third stream?
>>
>> I tried doing
>> mergedDS = datastream1.connect(datastream2)
>> iterateDS = mergedDS.iterate().withFeedback(datastream3type.class)
>>
>> but this didnt work and it was showing me errors.
>>
>> Is there any other way past this?
>>
>> Thanks
>>
>>
>>
>> --
>> View this message in context:
>> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Connect-2-datastreams-and-iterate-tp7009.html
>> Sent from the Apache Flink User Mailing List archive. mailing list
>> archive at Nabble.com.





--
View this message in context: 
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Connect-2-datastreams-and-iterate-tp7009p7131.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at 
Nabble.com.