Re: ConnectedStream keyby issues

2017-05-22 Thread Aljoscha Krettek
be gc when > the second event arrives? > > And if we have: > Example 2 > public void onTimer(.) > { > // do some work > // no timer registeration > } > Will it be gc after completion of onTimer ? > > > > >

Re: ConnectedStream keyby issues

2017-05-19 Thread Renjie Liu
is it limited to what? > > I am new with this framework I find difficulty in some notions. > > Best Regards, > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13228.ht

Re: ConnectedStream keyby issues

2017-05-19 Thread Tarek khal
flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13228.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: ConnectedStream keyby issues

2017-05-19 Thread Renjie Liu
che-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13226.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. > -- Liu, Renjie Software Engineer, MVAD

Re: ConnectedStream keyby issues

2017-05-19 Thread Tarek khal
Hello Renjie, Yes, the parallelism is 1. what should i do pls ? Regards, -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13226.html Sent from the Apache Flink User Mailing List archive. mailing list

Re: ConnectedStream keyby issues

2017-05-19 Thread Renjie Liu
-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13003.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. > -- Liu, Renjie Software Engineer, MVAD

Re: ConnectedStream keyby issues

2017-05-19 Thread gaurav
ling-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13219.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: ConnectedStream keyby issues

2017-05-11 Thread Aljoscha Krettek
tor) throws Exception { >if (state.value() != null) { >collector.collect(state.value()); >state.update(null); >} >} > > > > -- > View this message in context: > http://apache-flink-user-mailing-li

Re: ConnectedStream keyby issues

2017-05-10 Thread yunfan123
ect(state.value()); state.update(null); } } -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13090.html Sent from the Apache Flink User Mailing List archive. mailing list arch

Re: ConnectedStream keyby issues

2017-05-10 Thread yunfan123
in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13089.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: ConnectedStream keyby issues

2017-05-09 Thread Aljoscha Krettek
Can I set a timeout? > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13037.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.

Re: ConnectedStream keyby issues

2017-05-07 Thread yunfan123
But what happened if some data can't be merged forever ? The state will be saved forever? Can I set a timeout? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13037.html Sent from the Apache Flink

Re: ConnectedStream keyby issues

2017-05-04 Thread Tarek khal
Hi Jason, Thank you very much for your help, it solves my problem. Best regards, -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999p13003.html Sent from the Apache Flink User Mailing List archive. mailing

Re: ConnectedStream keyby issues

2017-05-04 Thread Jason Brelloch
Tuple2(); > } > > @Override > public void flatMap2(RulesEvent rulesEvent, > Collector> collector) throws Exception { > t2.f1 = rulesEvent; > //collector.collect(t2); > } > }); > ds.printToErr();

ConnectedStream keyby issues

2017-05-04 Thread Tarek khal
ector.collect(t2); } }); ds.printToErr(); Best, -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ConnectedStream-keyby-issues-tp12999.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.