Re: flink - Working with State example

> Buvana > > -Original Message- > From: Kostas Kloudas [mailto:k.klou...@data-artisans.com] > Sent: Friday, August 12, 2016 1:37 AM > To: user@flink.apache.org > Subject: Re: flink - Working with State example > > No problem! > > Regards, > Kostas > > >

RE: flink - Working with State example

/ sub dir there. Please explain. Thanks, Buvana -Original Message- From: Kostas Kloudas [mailto:k.klou...@data-artisans.com] Sent: Friday, August 12, 2016 1:37 AM To: user@flink.apache.org Subject: Re: flink - Working with State example No problem! Regards, Kostas > On Aug 12, 201

Re: flink - Working with State example

ssage- > From: Kostas Kloudas [mailto:k.klou...@data-artisans.com] > Sent: Thursday, August 11, 2016 11:22 AM > To: user@flink.apache.org > Subject: Re: flink - Working with State example > > Hi Buvana, > > At a first glance, your snapshotState() should return a Doubl

RE: flink - Working with State example

Kostas, Good catch! That makes it working! Thank you so much for the help. Regards, Buvana -Original Message- From: Kostas Kloudas [mailto:k.klou...@data-artisans.com] Sent: Thursday, August 11, 2016 11:22 AM To: user@flink.apache.org Subject: Re: flink - Working with State example Hi

Re: flink - Working with State example

ee the full stack trace of the errors, re-run Maven with the -e > switch. > [ERROR] Re-run Maven using the -X switch to enable full debug logging. > [ERROR] > [ERROR] For more information about the errors and possible solutions, please > read the following articles: > [ERROR

RE: flink - Working with State example

== -Original Message- From: Kostas Kloudas [mailto:k.klou...@data-artisans.com] Sent: Thursday, August 11, 2016 10:34 AM To: user@flink.apache.org Subject: Re: flink - Working with State example Exactly as Ufuk suggested, if you are not group

Re: flink - Working with State example

tp.setField(INPUT_KAFKA_TOPIC, 0); >> >>tp.setField(value2, 1); >> >>out.collect(tp); >> >> >> >>} catch (NumberFormatException e) { >> >>System.out.println(&quo

Re: flink - Working with State example

; > System.err.println("Could not convert to Float" + > incString); > > } > > } > > > > @Override > > public void open(Configuration config) { > > ValueStateDescriptor<Tuple2<Str

RE: flink - Working with State example

;() {}), // type information Tuple2.of("test topic", 0.0)); // default value of the state, if nothing was set prev_tuple = getRuntimeContext().getState(descriptor); } } } From: Kostas Kloudas [mailto:k.klou...@data-artisans.com] Sent: Thursday,

flink - Working with State example

Hello, I am utilizing the code snippet in: https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/state.html and particularly ‘open’ function in my code: @Override public void open(Configuration config) { ValueStateDescriptor> descriptor =