flink1.10 stop with a savepoint失败

Mon, 19 Oct 2020 00:42:13 -0700 

普通的source -> map -> filter-> sink 测试应用。

触发savepoint的脚本 ：
    ${FLINK_HOME} stop -p ${TARGET_DIR} -d ${JOB_ID}
具体报错信息：

org.apache.flink.util.FlinkException: Could not stop with a savepoint job
"81990282a4686ebda3d04041e3620776".
        at
org.apache.flink.client.cli.CliFrontend.lambda$stop$5(CliFrontend.java:462)
        at
org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:843)
        at org.apache.flink.client.cli.CliFrontend.stop(CliFrontend.java:454)
        at
org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:907)
        at
org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:968)
        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:1962)
        at
org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
        at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:968)
Caused by: java.util.concurrent.TimeoutException
        at
java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1771)
        at 
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915)
        at
org.apache.flink.client.cli.CliFrontend.lambda$stop$5(CliFrontend.java:460)
        ... 9 more


查看报错，怀疑是权限问题，我是root用户启动的应用，savepoint目录所在的hdfs路径权限所属也是root，如果不停止应用，直接触发savepoint没问题，继续定位到是root用户去停止hadoop
应用遇到权限问题，但是不知道怎么解决，目前卡在这里。



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复