问题一：Flink提交任务到yarn 集群 报错？有遇到过类似的错误吗？
Flink提交任务到yarn 集群 报错？有大佬遇到过类似的错误吗？Diagnostics from YARN: Application application_1715652296904_0003 failed 1 times (global limit =2; local limit is =1) due to AM Container for appattempt_1715652296904_0003_000001 exited with exitCode: 127
参考答案：
遇到Flink任务提交到YARN集群失败，并且收到包含exitCode: 127的错误信息时，这通常指示着应用程序主容器（Application Master, AM）启动时出现了问题。错误码127通常意味着命令未找到或者执行脚本有问题。以下是可能的原因和解决方法：
环境配置问题：
确保Flink的依赖和环境变量在YARN集群的节点上正确设置。特别是，检查FLINK_HOME环境变量是否被所有节点正确识别，并且Flink的二进制文件和库路径是否可访问。
可执行权限问题：
检查Flink的启动脚本（如flink-dist.sh或相关启动命令）是否有正确的执行权限。可以尝试在YARN的节点上手动运行这些脚本看是否能成功执行。
Shell命令或脚本错误：
错误码127有时也意味着YARN尝试执行的启动命令或脚本中存在错误。检查你的Flink作业提交命令以及任何自定义的启动脚本，确保没有语法错误或命令路径错误。
资源问题：
虽然错误码127直接指向执行问题而非资源不足，但资源限制也可能间接导致脚本执行失败。确认YARN为应用分配的资源（内存、CPU等）是否满足Flink作业的需求。
日志分析：
查看YARN的application logs，特别是AM容器的日志（可以通过YARN的Web UI访问），以获取更详细的错误信息。这些日志可能会揭示具体是哪个命令或操作导致了退出码127。
Hadoop和Flink版本兼容性：
确认你的Flink版本与YARN集群上的Hadoop版本兼容。不兼容的版本组合可能导致某些功能不正常工作。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/626075
问题二：Flink数据同步过程中发生错误，怎么保证作业重启后从这个时间点之前传递？
Flink数据同步过程中发生错误，怎么保证作业重启后从这个时间点之前传递？保证数据的完整性
参考答案：
作业错误，一般是发生Failover ，解决错误点后，重启作业默认是从上次成功的 checkpoint 位点恢复，下游使用幂等的结果表，数据追上最终结果是正确的，如果任务 failed 了，要看 failed 前有没有成功的 checkpoint 位点，手动重启时从状态恢复，使用幂等类型的结果表同上，如果产生错误，首先查看原因，解决错误，最后根据有状态重启作业。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/622012
问题三：Flink任务提交后出现这个异常要怎么处理呀 ？
Flink任务提交后出现这个异常要怎么处理呀 ？ 
参考答案：
看报错是JobManager还正在初始化，无法接受请求操作。可以等JobManager初始化完成之后再重新提交任务。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/654883
问题四：Flink获取消费kafka的时候始终获取不到topic列表是啥原因啊？
Flink获取消费kafka的时候始终获取不到topic列表是啥原因啊？Caused by: org.apache.flink.util.FlinkRuntimeException: Failed to list subscribed topic partitions due to
at org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator.checkPartitionChanges(KafkaSourceEnumerator.java:283)
at org.apache.flink.runtime.source.coordinator.ExecutorNotifier.lambda$null$1(ExecutorNotifier.java:83)
at org.apache.flink.util.ThrowableCatchingRunnable.run(ThrowableCatchingRunnable.java:40)
... 7 more
Caused by: java.lang.RuntimeException: Failed to get metadata for topics [board_quote_topic].
at org.apache.flink.connector.kafka.source.enumerator.subscriber.KafkaSubscriberUtils.getTopicMetadata(KafkaSubscriberUtils.java:47)
at org.apache.flink.connector.kafka.source.enumerator.subscriber.TopicListSubscriber.getSubscribedTopicPartitions(TopicListSubscriber.java:52)
at org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator.getSubscribedTopicPartitions(KafkaSourceEnumerator.java:268)
at org.apache.flink.runtime.source.coordinator.ExecutorNotifier.lambda$notifyReadyAsync$2(ExecutorNotifier.java:80)
... 7 more
Caused by: java.util.concurrent.ExecutionException: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeTopics
at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
at org.apache.flink.kafka.shaded.org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
at org.apache.flink.connector.kafka.source.enumerator.subscriber.KafkaSubscriberUtils.getTopicMetadata(KafkaSubscriberUtils.java:44)
... 10 more
Caused by: org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node assignment. Call: describeTopics 报错信息
参考答案：
可能的原因多台机器都要配置下/etc/hosts的配置映射。
排查过程如下：
先看下kafka的进程信息
ps -ef |grep kafka
然后看下如下配置信息
/var/run/cloudera-scm-agent/process/405-kafka-KAFKA_BROKER/kafka.properties
这里看到里面的zk使用了映射的名字
因为zk的连接过程是通过映射名称来通信的。
——参考链接。
关于本问题的更多回答可点击进行查看：
https://developer.aliyun.com/ask/627758
问题五：Flink发生两个表连接报错了，要怎么解决？
维表sql注入
流表dataStream生成 
Flink发生两个表连接报错了，要怎么解决？
参考答案：
两边的类型可能有问题
关于本问题的更多回答可点击进行查看：
