Cannot run using a savepoint with the same jar

Hi, I have a flink job that I can trigger a save point for with no problem. However, If I cancel the job then try to run it with the save point, I get the following exception. Any ideas how can I debug or fix it? I am using the exact same jar so I did not modify the program in any manner.

Re: Replace Flink job while cluster is down

ed. With HA, > you would need to manually remove the corresponding entry from Zookeeper. If > this is the problem, I suggest using Flink’s Zookeeper namespaces feature, to > isolate different runs of a job. > > Best, > Stefan > > >> Am 07.12.2016 um 13:20 schrieb Al-Isawi Ram

Replace Flink job while cluster is down

Hi, I have faulty flink streaming program running on a cluster that is consuming from kafka,so I brought the cluster down. Now I have a new version that has the fix. Now if I bring up the flink cluster again, the old faulty program will be recovered and it will consume and stream faulty

Re: TumblingEventTimeWindows with time characteristic set to 'ProcessingTime'

aracteristic(TimeCharacteristic.EventTime);? Otherwise the event time windows won’t work. Cheers, Till ​ On Tue, Aug 16, 2016 at 2:42 PM, Al-Isawi Rami <rami.al-is...@comptel.com<mailto:rami.al-is...@comptel.com>> wrote: Hi, Why this combination is not possible? even though I am setting "

TumblingEventTimeWindows with time characteristic set to 'ProcessingTime'

Hi, Why this combination is not possible? even though I am setting "assignTimestampsAndWatermarks “ correctly on the DataStream. I would like Flink to be ticking on processing time, but also utilize the TumblingEventTimeWindows which is based on event time. It is not possible because of :

Re: Multi-field "sum" function just like "keyBy"

-Jamie On Tue, Jun 7, 2016 at 5:41 AM, Al-Isawi Rami <rami.al-is...@comptel.com<mailto:rami.al-is...@comptel.com>> wrote: Hi, Is there any reason why “keyBy" accepts multi-field, while for example “sum” does not. -Rami Disclaimer: This message and any attachments thereto

Re: Multi-field "sum" function just like "keyBy"

Best, Gábor 2016-06-07 14:41 GMT+02:00 Al-Isawi Rami <rami.al-is...@comptel.com<mailto:rami.al-is...@comptel.com>>: Hi, Is there any reason why “keyBy" accepts multi-field, while for example “sum” does not. -Rami Disclaimer: This message and any attachments thereto are intend

Multi-field "sum" function just like "keyBy"

Hi, Is there any reason why “keyBy" accepts multi-field, while for example “sum” does not. -Rami Disclaimer: This message and any attachments thereto are intended solely for the addressed recipient(s) and may contain confidential information. If you are not the intended recipient, please

Re: keyBy on a collection of Pojos

ic void setProductId(String productId) { this.productId = productId; } } On Mon, May 23, 2016 at 3:40 PM, Al-Isawi Rami <rami.al-is...@comptel.com<mailto:rami.al-is...@comptel.com>> wrote: Thanks Flavio, but as you can see in my code I have already declared my pojo to achieve those cond

Re: keyBy on a collection of Pojos

t be getters and setters for all non-public fields. If the field name is foo the getter and setters must be called getFoo() and setFoo(). I don't know whether you need to implement also hashCode() and equals() actually Best, Flavio On Mon, May 23, 2016 at 3:24 PM, Al-Isawi Rami <rami.al-is