Re: Reprocessing data in Flink / rebuilding Flink state

2016-07-29 Thread Jagat Singh
Hi, This might be useful to you https://www.mapr.com/blog/savepoints-apache-flink-stream-processing-whiteboard-walkthrough Thanks, Jagat Singh On 29 July 2016 at 20:59, Aljoscha Krettek wrote: > Hi, > I think the exact thing you're trying do do is not possible right now but &g

Re: How to pass hdp.version to flink on yarn

2015-11-23 Thread Jagat Singh
Hello Robert, Added following env.java.opts: "-Dstack.name=phd -Dstack.version=3.0.0.0-249" Same Error Is there any config which allows to pass special java opts to actual yarn containers? Thanks, Jagat Singh On Mon, Nov 23, 2015 at 9:21 PM, Robert Metzger wrote: > Hi,

How to pass hdp.version to flink on yarn

2015-11-22 Thread Jagat Singh
Hi, I am running example Flink program (Pivotal HDP) ./bin/flink run -m yarn-cluster -yn 2 ./examples/WordCount.jar I am getting error below. How to pass the stack.name and stack.version to the flink program. This is similar to what we give to Spark as hdp.version. Example spark.driver.extr