DTStack / DTStack/chunjun

[Question][Launcher]Yarn Session模式提交任务之后无响应

Open
#1,839 0 comments 0 reactions 0 assignees View on GitHub
question
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

### Search before asking

- [x] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar question.

- [x] I had googled my question but i didn't get any help.

- [x] I had read the documentation: [ChunJun doc](https://dtstack.github.io/chunjun) but it didn't help me.

### Description

版本:flinkx 1.10
在yarn session 模式时,开启kerberos认证,提交任务后只输出如下日志就一直无响应。但使用yarnPer、local均能正常执行,求助该如何排查?

执行日志:
[root@bd-node1 flinkx]# /hadoop-data/flinkx/bin/flinkx -mode yarn -job /hadoop-data/flinkx/stream_stream.json -flinkconf /hadoop-data/flink-1.10.2/conf -yarnconf /etc/hadoop/conf -pluginLoadMode shipfile
flinkx starting ...
15:51:44.914 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.address, localhost
15:51:44.916 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.rpc.port, 6123
15:51:44.916 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.heap.size, 8G
15:51:44.916 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.memory.process.size, 8G
15:51:44.916 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.numberOfTaskSlots, 1
15:51:44.916 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: parallelism.default, 1
15:51:44.917 [main] INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.execution.failover-strategy, region
log4j:WARN No appenders could be found for logger (org.apache.hadoop.util.Shell).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.

### Code of Conduct

- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.