You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 星沉 <st...@fallenstar.xyz> on 2019/09/30 06:47:40 UTC

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

savepoint路径参数不对。file后面多了个一个/吧。


pengchenglins@163.com wrote:
> $ bin/flink savepoint -dfile:///home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/
> 
> ------------------------------------------------------------
>   The program finished with the following exception:
> 
> java.lang.NullPointerException: Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>

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

Posted by 赢峰 <si...@163.com>.

这个有解决吗?我的也是报 Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>
| |
赢峰
|
|
si_ji_feng@163.com
|
签名由网易邮箱大师定制


On 09/30/2019 15:06,pengchenglins@163.com<pe...@163.com> wrote:
你好,感谢回复,我的命令是参照官方网站,https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/state/savepoints.html#trigger-a-savepoint
$ bin/flink savepoint -d :savepointPath
这个命令是删除savepoint,你说的是触发savepoint,是没有问题的。


pengchenglins@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 <jobId> [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
|
|
diyukun2019@163.com
|
签名由网易邮箱大师定制
On 9/30/2019 14:56,pengchenglins@163.com<pe...@163.com> wrote:
谢谢你的回复,我试了下,还是说缺少必填参数。
如下:
$ bin/flink savepoint -d file://home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/

------------------------------------------------------------
The program finished with the following exception:

java.lang.NullPointerException: Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>
at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:75)
at org.apache.flink.client.cli.CliFrontend.disposeSavepoint(CliFrontend.java:721)
at org.apache.flink.client.cli.CliFrontend.lambda$savepoint$8(CliFrontend.java:657)
at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:945)
at org.apache.flink.client.cli.CliFrontend.savepoint(CliFrontend.java:654)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1025)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1556)
at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083)




pengchenglins@163.com

发件人: 星沉
发送时间: 2019-09-30 14:47
收件人: user-zh
主题: Re: Command: Flink savepoint -d reported an error。
savepoint路径参数不对。file后面多了个一个/吧。


pengchenglins@163.com wrote:
$ bin/flink savepoint -dfile:///home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/

------------------------------------------------------------
The program finished with the following exception:

java.lang.NullPointerException: Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>

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

Posted by "pengchenglins@163.com" <pe...@163.com>.
你好,感谢回复,我的命令是参照官方网站,https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/state/savepoints.html#trigger-a-savepoint
$ bin/flink savepoint -d :savepointPath
这个命令是删除savepoint,你说的是触发savepoint,是没有问题的。


pengchenglins@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 <jobId> [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
|
|
diyukun2019@163.com
|
签名由网易邮箱大师定制
On 9/30/2019 14:56,pengchenglins@163.com<pe...@163.com> wrote:
谢谢你的回复,我试了下,还是说缺少必填参数。
如下:
$ bin/flink savepoint -d file://home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/
 
------------------------------------------------------------
The program finished with the following exception:
 
java.lang.NullPointerException: Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>
at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:75)
at org.apache.flink.client.cli.CliFrontend.disposeSavepoint(CliFrontend.java:721)
at org.apache.flink.client.cli.CliFrontend.lambda$savepoint$8(CliFrontend.java:657)
at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:945)
at org.apache.flink.client.cli.CliFrontend.savepoint(CliFrontend.java:654)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1025)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1556)
at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083)
 
 
 
 
pengchenglins@163.com
 
发件人: 星沉
发送时间: 2019-09-30 14:47
收件人: user-zh
主题: Re: Command: Flink savepoint -d reported an error。
savepoint路径参数不对。file后面多了个一个/吧。
 
 
pengchenglins@163.com wrote:
$ bin/flink savepoint -dfile:///home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/
 
------------------------------------------------------------
The program finished with the following exception:
 
java.lang.NullPointerException: Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>

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

Posted by 狄玉坤 <di...@163.com>.
缺少了jobId 参数;
./bin/flink savepoint <jobId> [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
|
|
diyukun2019@163.com
|
签名由网易邮箱大师定制
On 9/30/2019 14:56,pengchenglins@163.com<pe...@163.com> wrote:
谢谢你的回复,我试了下,还是说缺少必填参数。
如下:
$ bin/flink savepoint -d file://home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/

------------------------------------------------------------
The program finished with the following exception:

java.lang.NullPointerException: Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>
at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:75)
at org.apache.flink.client.cli.CliFrontend.disposeSavepoint(CliFrontend.java:721)
at org.apache.flink.client.cli.CliFrontend.lambda$savepoint$8(CliFrontend.java:657)
at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:945)
at org.apache.flink.client.cli.CliFrontend.savepoint(CliFrontend.java:654)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1025)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1556)
at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083)




pengchenglins@163.com

发件人: 星沉
发送时间: 2019-09-30 14:47
收件人: user-zh
主题: Re: Command: Flink savepoint -d reported an error。
savepoint路径参数不对。file后面多了个一个/吧。


pengchenglins@163.com wrote:
$ bin/flink savepoint -dfile:///home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/

------------------------------------------------------------
The program finished with the following exception:

java.lang.NullPointerException: Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>

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

Posted by "pengchenglins@163.com" <pe...@163.com>.
谢谢你的回复,我试了下,还是说缺少必填参数。
如下:
$ bin/flink savepoint -d file://home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/

------------------------------------------------------------
 The program finished with the following exception:

java.lang.NullPointerException: Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>
at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:75)
at org.apache.flink.client.cli.CliFrontend.disposeSavepoint(CliFrontend.java:721)
at org.apache.flink.client.cli.CliFrontend.lambda$savepoint$8(CliFrontend.java:657)
at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:945)
at org.apache.flink.client.cli.CliFrontend.savepoint(CliFrontend.java:654)
at org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1025)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1556)
at org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1083)




pengchenglins@163.com
 
发件人: 星沉
发送时间: 2019-09-30 14:47
收件人: user-zh
主题: Re: Command: Flink savepoint -d reported an error。
savepoint路径参数不对。file后面多了个一个/吧。
 
 
pengchenglins@163.com wrote:
> $ bin/flink savepoint -dfile:///home/pengchenglin/flinkresult/savepoint/savepoint-ffbc58-9daf3085de9a/
> 
> ------------------------------------------------------------
>   The program finished with the following exception:
> 
> java.lang.NullPointerException: Missing required argument: savepoint path. Usage: bin/flink savepoint -d <savepoint-path>