Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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

Open
4 tasks done
windyalsy opened this issue Oct 24, 2023 · 0 comments
Open
4 tasks done

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

windyalsy opened this issue Oct 24, 2023 · 0 comments
Labels
question Further information is requested

Comments

@windyalsy
Copy link

windyalsy commented Oct 24, 2023

Search before asking

  • I had searched in the issues and found no similar question.

  • I had googled my question but i didn't get any help.

  • I had read the documentation: ChunJun doc 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

@windyalsy windyalsy added the question Further information is requested label Oct 24, 2023
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
question Further information is requested
Projects
None yet
Development

No branches or pull requests

1 participant