Do you really need to iterate ?
On Mon, Oct 19, 2015 at 5:42 PM, flinkuser wrote:
>
> Here is my code snippet but I find the union operator not workable.
>
> DataStream msgDataStream1 = env.addSource((new
> SocketSource(hostName1,port,'\n',-1))).filter(new
> MessageFilter()).setParallelism(1);
>
Hi!
Two comments:
(1) The iterate() statement is probably wrong, as noticed by Anwar.
(2) Which version of Flink are you using? In 0.9.x, the Union operator is
not lock-safe, in 0.10, it should work well. The 0.10 release is coming up
shortly, you can try the 0.10-SNAPSHOT version already.
Gree
Here is the strange behavior.
Below code works in one box but not in the other. I had it working in my
laptop the whole of yesterday, but strangely today it doesnt work in my
desktop.
Can anyone please let me know what the issue is.
public static void main(String[] args) throws Exception {
Can it be that you forgot to call unionMessageStreams in your main method?
Cheers,
Till
On Wed, Oct 21, 2015 at 3:02 PM, flinkuser wrote:
> Here is the strange behavior.
>
> Below code works in one box but not in the other. I had it working in my
> laptop the whole of yesterday, but strangely
Hi Gayu,
could it be that no data ever arrives on the second input stream? Or that the
filter filters out all messages?
Also, in the example you posted you forgot to call unionMessageStreams().
Cheers,
Aljoscha
> On 21 Oct 2015, at 15:29, Till Rohrmann wrote:
>
> Can it be that you forgot to
The data does arrive in the second port and i am able to see that in the
filter class received.
It happens only on specific machine on which i run the code.
Yes, i did forget to post here, but my program calls the
unionMessageStreams()
On Wed, Oct 21, 2015 at 9:39 AM, Aljoscha Krettek <
aljoscha
So it is received in the filter but the print afterwards does not print?
> On 21 Oct 2015, at 15:49, Gayu wrote:
>
> The data does arrive in the second port and i am able to see that in the
> filter class received.
> It happens only on specific machine on which i run the code.
>
>
> Yes, i did
Yes, exactly.
On Wed, Oct 21, 2015 at 10:17 AM, Aljoscha Krettek <
aljoscha.kret...@gmail.com> wrote:
> So it is received in the filter but the print afterwards does not print?
> > On 21 Oct 2015, at 15:49, Gayu wrote:
> >
> > The data does arrive in the second port and i am able to see that in
So does the filter maybe filter out everything?
> On 21 Oct 2015, at 16:18, Gayu wrote:
>
> Yes, exactly.
>
> On Wed, Oct 21, 2015 at 10:17 AM, Aljoscha Krettek
> wrote:
> So it is received in the filter but the print afterwards does not print?
> > On 21 Oct 2015, at 15:49, Gayu wrote:
> >
>
No, it doesn't i even tried removing the filter and return all the values
as is received from the port.
My doubt is, is there anything system or CPU specific that fails to attach
the data to the datastream created.
On Wed, Oct 21, 2015 at 10:39 AM, Aljoscha Krettek <
aljoscha.kret...@gmail.com> w
Hmm, that is strange.
Could you maybe send the complete program so that I could have a look?
> On 21 Oct 2015, at 16:43, Gayu wrote:
>
> No, it doesn't i even tried removing the filter and return all the values as
> is received from the port.
>
> My doubt is, is there anything system or CPU sp
Hi,
first of all, am I correct to assume that
new SocketSource(hostName1, port, '\n', -1)
should be
new SocketTextStreamFunction(hostName1, port1, '\n', -1)
or are you using a custom built SocketSource for this?
If I replace it by SocketTextStreamFunction and execute it the example runs and
prin
I think the most crucial question is still whether you are running 0.9.1 or
0.10-SNAPSHOT, because the 0.9.1 union has known issues...
If you are running 0.9.1 there is not much you can do except upgrade the
version ;-)
On Wed, Oct 21, 2015 at 5:19 PM, Aljoscha Krettek
wrote:
> Hi,
> first of al
13 matches
Mail list logo
