Hi, 看日志application已经提交到yarn了，但是am没有调度起来，看一下Yarn界面application_1620481460888_0003 这个application的状态是什么？有没有报错
Best, Yangze Guo On Mon, May 10, 2021 at 9:41 AM [email protected] <[email protected]> wrote: > > 您好，在使用flink on YARN的时候遇到了问题，寻求帮助，YARN集群搭建完成之后，运行flink命令如下： > ./bin/flink run -t yarn-per-job --detached ./examples/batch/WordCount.jar > 但是发现没有输出运行结果，日志如下 > Executing WordCount example with default input data set. > Use --input to specify file input. > Printing result to stdout. Use --output to specify output path. > 2021-05-08 21:53:46,561 WARN > org.apache.flink.yarn.configuration.YarnLogConfigUtil [] - The > configuration directory ('/mnt/flink-1.12.3/conf') already contains a LOG4J > config file.If you want to use logback, then please delete or rename the log > configuration file. > 2021-05-08 21:53:46,611 INFO > org.apache.hadoop.yarn.client.DefaultNoHARMFailoverProxyProvider [] - > Connecting to ResourceManager at node01/172.19.0.132:8032 > 2021-05-08 21:53:46,925 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - No path for the flink jar passed. Using the location of > class org.apache.flink.yarn.YarnClusterDescriptor to locate the jar > 2021-05-08 21:53:47,159 INFO org.apache.hadoop.conf.Configuration > [] - resource-types.xml not found > 2021-05-08 21:53:47,160 INFO > org.apache.hadoop.yarn.util.resource.ResourceUtils [] - Unable to > find 'resource-types.xml'. > 2021-05-08 21:53:47,224 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - The configured JobManager memory is 1600 MB. YARN will > allocate 2048 MB to make up an integer multiple of its minimum allocation > memory (1024 MB, configured via 'yarn.scheduler.minimum-allocation-mb'). The > extra 448 MB may not be used by Flink. > 2021-05-08 21:53:47,224 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - The configured TaskManager memory is 1728 MB. YARN will > allocate 2048 MB to make up an integer multiple of its minimum allocation > memory (1024 MB, configured via 'yarn.scheduler.minimum-allocation-mb'). The > extra 320 MB may not be used by Flink. > 2021-05-08 21:53:47,225 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - Cluster specification: > ClusterSpecification{masterMemoryMB=1600, taskManagerMemoryMB=1728, > slotsPerTaskManager=1} > 2021-05-08 21:53:53,360 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - Submitting application master application_1620481460888_0003 > 2021-05-08 21:53:53,425 INFO > org.apache.hadoop.yarn.client.api.impl.YarnClientImpl [] - Submitted > application application_1620481460888_0003 > 2021-05-08 21:53:53,425 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - Waiting for the cluster to be allocated > 2021-05-08 21:53:53,427 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - Deploying cluster, current state ACCEPTED > 2021-05-08 21:54:53,548 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - Deployment took more than 60 seconds. Please check if the > requested resources are available in the YARN cluster > 2021-05-08 21:54:53,825 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - Deployment took more than 60 seconds. Please check if the > requested resources are available in the YARN cluster > 2021-05-08 21:54:54,077 INFO org.apache.flink.yarn.YarnClusterDescriptor > [] - Deployment took more than 60 seconds. Please check if the > requested resources are available in the YARN cluster > > 代码里输出的内容正常打印，但是没有打印结果 > flink版本 1.12.3 Hadoop版本3.3.0 > 期望得到您的回复 > > > > [email protected]
