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

to: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 Double. > > Kostas > >> On

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

home/buvana/flink/flink-1.1.0/wiki-edits/src/main/java/wikiedits/stateful.java:[150,9] > method does not override or implement a method from a supertype > [ERROR] -> [Help 1] > [ERROR] > [ERROR] To see 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

RE: flink - Working with State example

lou...@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 grouping your stream by key, you should use the checkpointed interface. The reason I asked before if you are usi

Re: flink - Working with State example

>> >>Tuple2 tp = new Tuple2(); >> >>tp.setField(INPUT_KAFKA_TOPIC, 0); >> >>tp.setField(value2, 1); >> >> out.collect(tp); >> >> >> >>} catch (NumberFormatException e) { >> >&

Re: flink - Working with State example

tln("Could not convert to Float" + > incString); > > System.err.println("Could not convert to Float" + > incString); > > } > > } > > > > @Override > > public void open(Configuration co

RE: flink - Working with State example

TypeInformation.of(new TypeHint>() {}), // 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...@d

Re: flink - Working with State example

Hello Buvana, Can you share a bit more details on your operator and how you are using it? For example, are you using keyBy before using you custom operator? Thanks a lot, Kostas > On Aug 10, 2016, at 10:03 PM, Ramanan, Buvana (Nokia - US) > wrote: > > Hello, > > I am utilizing the code snip