Command: Flink savepoint -d reported an error。

2019-09-29 Thread pengchengl...@163.com
Hello everyone, Command: Flink savepoint -d reported an error。Do you know what's wrong with this command? $ bin/flink savepoint -d file:///home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/ The program fin

Re: Command: Flink savepoint -d reported an error。

2020-12-27 Thread 赢峰
-a-savepoint $ bin/flink savepoint -d :savepointPath 这个命令是删除savepoint,你说的是触发savepoint,是没有问题的。 pengchengl...@163.com 发件人: 狄玉坤 发送时间: 2019-09-30 14:59 收件人: user-zh@flink.apache.org 主题: Re: Re: Command: Flink savepoint -d reported an error。 缺少了jobId 参数; ./bin/flink savepoint [savepointDirectory

Re: Command: Flink savepoint -d reported an error。

2019-09-29 Thread 星沉
savepoint路径参数不对。file后面多了个一个/吧。 pengchengl...@163.com wrote: $ bin/flink savepoint -dfile:///home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/ The program finished with the following exception: java.lang.NullP

Re: Re: Command: Flink savepoint -d reported an error。

2019-09-29 Thread pengchengl...@163.com
(HadoopSecurityContext.java:41) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083) pengchengl...@163.com 发件人: 星沉 发送时间: 2019-09-30 14:47 收件人: user-zh 主题: Re: Command: Flink savepoint -d reported an error。 savepoint路径参数不对。file后面多了个一个/吧。 pengchengl...@163.com wrote: > $

Re: Re: Command: Flink savepoint -d reported an error。

2019-09-30 Thread 狄玉坤
org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083) pengchengl...@163.com 发件人: 星沉 发送时间: 2019-09-30 14:47 收件人: user-zh 主题: Re: Command: Flink savepoint -d reported an error。 savepoint路径参数不对。file后面多了个一个/吧。 pengchengl...@163.com

Re: Re: Command: Flink savepoint -d reported an error。

2019-09-30 Thread pengchengl...@163.com
: Re: Re: Command: Flink savepoint -d reported an error。 缺少了jobId 参数; ./bin/flink savepoint [savepointDirectory] This will trigger a savepoint for the job with ID jobId, and returns the path of the created savepoint. You need this path to restore and dispose savepoints. | | diyukun2019 | | diyukun2