问答 2023-08-08 来自:开发者社区

Flink自定义函数报这个错,怎么解决?我现在udf的版本和任务选择的引擎版本是一致的。

Flink自定义函数报这个错,怎么解决?我现在udf的版本和任务选择的引擎版本是一致的。java.lang.IncompatibleClassChangeError: Found class org.apache.flink.table.functions.FunctionContext, but interface was expected at com.aliyun.security.clo....

问答 2023-08-07 来自:开发者社区

DataWorks中flink任务一直在启动中是怎么回事?

DataWorks中flink任务一直在启动中是怎么回事?

问答 2023-08-02 来自:开发者社区

Flink CDC中我想用普罗米修斯prometheus对flink的任务做监控。针对flink批?

Flink CDC中我想用普罗米修斯prometheus对flink的任务做监控。针对flink批处理,遇到了一个问题,就是没有metrics能够反应。批处理无ck,没法从chekpoint入手。我想对可用性入手,但是发现,一旦批处理任务挂掉可用性指标(等等flink_jobmanager_job_failingState)就直接没了,根本抓不到,有大哥分享一下经验嘛?https://night....

问答 2023-08-02 来自:开发者社区

Flink CDC中pgsqlCDC 2.2版本停掉任务增加表之后恢复任务可以同步新表的数据吗?

Flink CDC中pgsqlCDC 2.2版本停掉任务增加表之后恢复任务可以同步新表的数据吗?我用的flink1.14+dinky0.73,我觉得flink版本应该不影响的,现在就是无法同步执行图也不太对

问答 2023-08-01 来自:开发者社区

大家有遇到过Flink CDC任务taskmanager拉起成功,但是不继续消费数据的情况吗?

大家有遇到过Flink CDC任务taskmanager拉起成功,但是不继续消费数据的情况吗?

问答 2023-08-01 来自:开发者社区

sqlserver的Flink CDC在latest-offset模式下,能停掉任务,?

sqlserver的Flink CDC在latest-offset模式下,能停掉任务,在tableList加一张表吗?希望能够正常接上checkpoint

问答 2023-08-01 来自:开发者社区

Flink CDC2.4.1版本,新加表之后,新加的表采集完全量,整个任务又卡住不继续读数据了?

Flink CDC2.4.1版本,新加表之后,新加的表采集完全量,整个任务又卡住不继续读数据了?initial,scan.incremental.snapshot.enabled=true,新加的这张表全量采集结束了,全量采集的时候之前的表的增量也在同步进行,但是快照阶段结束之后就卡住了,一直输出Binlog offset on checkpoint 4156: {ts_sec=0, file=....

问答 2023-08-01 来自:开发者社区

我们用Flink CDC2.4的mongodb cdc的时候发现,取近几个小时的时间戳任务是正常的?

我们用Flink CDC2.4的mongodb cdc的时候发现,取近几个小时的时间戳任务是正常的,但是如果取1天以前的时间戳启动任务时,任务会正常运行,但是不会有数据进来,新变动的数据也不会有。大佬知道为什么吗?

问答 2023-08-01 来自:开发者社区

请问Flink CDC使用tidb连接器的任务,通过flink restful api 的stop?

问题1:请问Flink CDC使用tidb连接器的任务,通过flink restful api 的stop方法 ,停止任务,抛出这个异常,请问是因为tidb数据库的binlog日志有问题影响的么?问题2:那是什么原因导致的么,现在是通过stop 方式,不能停止任务,任务会处于RESTARTING状态,然后又自行恢复了

问答 2023-08-01 来自:开发者社区

大佬们,Flink CDC中pgcdc在不开新任务的情况下支持订阅新加的表嘛?

大佬们,Flink CDC中pgcdc在不开新任务的情况下支持订阅新加的表嘛?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注