I'm sorry that I added some of my own code into the source code, and found
some mistakes. Now the problem has been solved, which is caused by my own
code
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi,
did you introduce some custom modifications to the code? Your stack trace does
not match the lines in the code of release-1.5.3, e.g. line 230 is not in
method internalTimeServiceManager(…) which makes it hard to draw any
conclusions.
Best,
Stefan
> Am 19.09.2018 um 14:03 schrieb spoon_lz
The stop order is：
/home/flink-1.5.3/bin/flink cancel ff31023d23e568290d5596a34aa3cad6 -yid
application_1526888270443_0336
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
I used flink1.3.2 before, and recently upgraded to flink1.5.3. I found
that the new version has adjusted checkpoint, and there was a problem after
modifying the code
My code like :
* RocksDBStateBackend rocksDBStateBackend = new
RocksDBStateBackend("hdfs://hdfs_1/demo/demo-fs-checkpoin
