Flink CDC现在怎么提交?
Flink CDC中我在sql文件里面写好了create table语句和insert 语句，现在怎么提交。
sql-client -f 之后，执行完了任务就都失败了
2023-09-27 17:31:58,725 INFO org.apache.flink.client.program.rest.RestClusterClient [] - Successfully submitted job 'insert-into_default_catalog.default_database.MYSQL_C_BILL_RELA_BF' (95b73a18ca2fb4fd3d3faa4f4f176f04) to 'http://127.0.0.1:8081'.
2023-09-27 17:31:58,886 INFO org.apache.flink.client.program.rest.RestClusterClient [] - Submitting job 'insert-into_default_catalog.default_database.MYSQL_C_GM_COMPEN' (7155ecfc43aa02e266f967107a43ac23).
2023-09-27 17:31:59,363 INFO org.apache.flink.client.program.rest.RestClusterClient [] - Successfully submitted job 'insert-into_default_catalog.default_database.MYSQL_C_GM_COMPEN' (7155ecfc43aa02e266f967107a43ac23) to 'http://127.0.0.1:8081'.
2023-09-27 17:31:59,501 INFO org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint [] - Shutting down rest endpoint.
2023-09-27 17:31:59,514 INFO org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint [] - Shut down complete.
2023-09-27 17:31:59,846 INFO org.apache.flink.table.gateway.rest.SqlGatewayRestEndpoint [] - Shutting down rest endpoint.？
[flink@wxc160 flink-bin]$ ./sql-client.sh embedded -f /app/flink/flink-1.17.0/sql/udf3.sql，执行命令写的这个
写回答
-
存在即是合理从日志中可以看到，提交了两个作业，但其中一个作业失败了。这可能是由于以下原因之一：
SQL的语法错误或逻辑错误。请检查您的SQL文件，确保它包含正确的CREATE TABLE语句和INSERT语句。
Flink集群配置可能不正确。请检查Flink配置文件（如flink-conf.yaml），确保所有必要的设置都已正确配置。
Flink集群资源不足。请检查您的Flink集群的资源使用情况，确保有足够的资源来运行您的作业。
Flink集群版本与代码不兼容。请检查Flink版本是否兼容。
2023-10-23 14:49:22赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
热门讨论
热门文章
相关文章
相关电子书
更多
