How can I get last successful checkpoint id in sink?

It seems flink not support this? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-can-I-get-last-successful-checkpoint-id-in-sink-tp13815.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: confusing RocksDBStateBackend parameters

Hi, To set the rocksdb state, you have two options: 1. Set the default state of the flink cluster, using the below parameters in flink-conf.yaml file state.backend: rocksdb state.backend.fs.checkpointdir: hdfs://namenode:40010/flink/checkpoints 2. Set a per job state backend (which overrides

java.lang.IllegalArgumentException with 1.3.0 and Elastic Search connector

Hi, after migrating to Flink 1.3.0, I started to get this exception when running in local mode: [error] (run-main-0) java.lang.IllegalArgumentException java.lang.IllegalArgumentException at org.apache.flink.shaded.org.objectweb.asm.ClassVisitor.(Unknown Source) at org.apache.flink.shaded.