请问一下：我使用命令行语句提交任务到native k8s上，能够创建pod，请问问题应该如何排查呀？
请问一下：我使用命令行语句提交任务到native k8s上，能够创建pod，但是任务不能运行成功（似乎直接不能初始化）。请问问题应该如何排查呀？下面是命令行语句和日志：
./bin/flink run-application --target kubernetes-application -Dkubernetes.cluster-id=cluster231115aa -Djobmanager.memory.process.size=1024m -Dtaskmanager.memory.process.size=8192m -Dkubernetes.taskmanager.cpu=1 -Dtaskmanager.numberOfTaskSlots=4 -Dkubernetes.container.image.ref=harbor.trawe.cn/common/pyflink2:1.17.1 -Dkubernetes.namespace=flink -Dkubernetes.rest-service.exposed.type=NodePort --pyModule ls_card_blacklist_id_k8s --pyFiles /opt/python_codes/ls_card_blacklist_id_k8s.py
k8s是1.27版，flink1.17.1版
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
-
根据您提供的信息，问题可能出在以下几个方面：
检查Flink和Kubernetes的版本是否兼容。您提到Flink版本为1.17.1，而Kubernetes版本为1.27。请确保这两个版本是兼容的。您可以查看官方文档以获取更多关于兼容性的信息。
检查您的Kubernetes集群配置是否正确。确保您的集群已经正确配置，并且可以正常访问。您可以使用
kubectl get nodes命令来查看集群中的节点信息。检查您的Flink配置文件是否正确。确保您的配置文件中包含了正确的Kubernetes相关配置，例如
jobmanager.rpc.address、taskmanager.rpc.address等。您可以查看官方文档以获取更多关于配置文件的信息。检查您的Python代码是否正确。确保您的Python代码没有语法错误或其他问题。您可以使用
pylint或flake8等工具来检查代码质量。查看Flink和Kubernetes的日志。您可以使用
kubectl logs命令来查看Pod的日志，以便更好地了解问题所在。
2023-11-21 15:34:42赞同 1 展开评论
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。