明月夜深沉 2021-12-30 09:30 采纳率: 60%
浏览 120
已结题

Flink-SQL-Client查询报:java.lang.IllegalArgumentException:Checkpoint is not supported for batch jobs.

flink-conf.yaml

img

sql-client-defaults.yaml

img

报错内容

img

大概原因我了解。是因为我在 sql-client-defaults.yaml 中把Type设置为batch，换成streaming就行了。但是如果我换成streaming，当我执行一条insert into 语句就会在Yarn上面生成一个application。并且当我的客户端推出后也一直存在，一直占用资源。所以我想试试batch模式下是否会这样。但是换成batch之后查询就会报一上面的错误。我个人理解，sql-client-defaults.yaml 是sql-client的配置，是否修改sql-client-defaults.yaml就可以了。但是看来并不行。不知道有什么解决方案。望各位不吝赐教！
  • 写回答

1条回答 默认 最新

  • BigDataToAI 2021-12-31 00:20
    关注

    如报错所述呢，您使用了batch模式，但是您在flink-conf.yaml配置文件中还配置了checkpoints相关的配置呢，如果您要使用batch模式，请先把flink-conf.yaml配置中的checkpoint相关配置删了呢。

    当然我们在使用的时候，其实是还有另外一种模式的呢，就是使用flink session模式，在该模式下往yarn session中提交任务，该模式下有任务提交了，会申请taskmanger，如果任务结束之后会释放taskmanager，也不失为一种好的测试方法呢

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题？

问题事件

  • 系统已结题 1月22日
  • 已采纳回答 1月14日
  • 创建了问题 12月30日

悬赏问题

  • ¥100 ensp启动设备蓝屏，代码clock_watchdog_timeout
  • ¥15 Android studio AVD启动不了
  • ¥15 陆空双模式无人机怎么做
  • ¥15 想咨询点问题，与算法转换，负荷预测，数字孪生有关
  • ¥15 C#中的编译平台的区别影响
  • ¥15 软件供应链安全是跟可靠性有关还是跟安全性有关？
  • ¥15 电脑蓝屏logfilessrtsrttrail问题
  • ¥20 关于wordpress建站遇到的问题！(语言-php)（相关搜索：云服务器）
  • ¥15 【求职】怎么找到一个周围人素质都很高不会欺负他人，并且未来月薪能够达到一万以上（技术岗）的工作？希望可以收到写有具体，可靠，已经实践过了的路径的回答？
  • ¥15 Java+vue部署版本反编译