flink sql 数据异常导致任务失败怎么办?
kafka source,一条异常数据就会导致任务失败,这种问题怎么解决呢? 以前用DatastreamAPI的话是自己解析,因此可以捕获异常,仅统计非法数据量作为flink的metric指标。 现在是基于flink sql直接基于kakfa创建动态表,查询动态表过程json解析失败,导致任务失败。*来自志愿者整理的flink邮件归档
提交两个SQL任务,其中一个不生效怎么办?
大家好,我通过Yarn Per Job模式提交了两个任务,后一个提交的任务会变成前一个一样的任务,而且好像不产生实际作用(?),看起来像是在给前一个做HA,不知道是不是什么配置没搞好呢? 两个任务分别是 Kafka Topic1 -> Kafka Topic2 和 Kafka Topic2 -> Postgre,两个任务中的Topic2用的是同一个。 之前也尝试过,Topic1同时写入...
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
SQL任务相关内容
- SQL任务优先级
- SQL任务yarn
- 跨项目SQL任务
- 任务上下文SQL
- 云数据任务SQL
- 数据计算SQL任务
- 大数据SQL任务
- SQL任务insert
- 任务实例SQL
- 任务库SQL
- 参数SQL任务
- 数据计算SQL任务运行
- 数据计算任务SQL
- hologres SQL任务
- SQL任务failed
- dms任务SQL
- dms任务编排SQL
- SQL计算任务
- SQL任务checkpoint
- dts SQL任务
- mapreduce SQL任务
- 产品任务SQL
- dts任务SQL
- 任务execute SQL
- SQL任务检查
- SQL任务计算
- SQL备份任务
- emr SQL任务
- 实时计算flink版产品SQL任务
- SQL任务task
SQL更多任务相关
数据库
分享数据库前沿,解构实战干货,推动数据库技术变革
+关注