DataWorks中 kafka 数据源同步到mc , 任务一直在执行中， 这种一般是什么问题呢？[阿里云]
DataWorks中 kafka 数据源同步到mc , 任务一直在执行中， 选择的同步是5分钟。这种一般是什么问题呢？ 以下为热心网友提供的参考意见 在...
Flink1.18.0版本连接外部kafka本地执行测试代码报错[阿里云]
版本：Flink1.18.0代码如下：```public static void main(String args) { //1、创建TableEnvironment EnvironmentSettings settings = E...
Flink这个问题怎么解决？[阿里云]
Flink这个问题怎么解决？数据库的binlog 是 先删除后新增，但是 cdc 解析到的是先新增后删除，使用的方式是，用flink sql 读取mysql bin...
Flink执行CREATE TABLE AS（CTAS）语句报错这个错，怎么解决？[阿里云]
Flink执行CREATE TABLE AS（CTAS）语句报错这个错，怎么解决？说这个表中kafka catalog中不存在，就是想执行这个语句创建这个表 以下为...
Flink怎么诊断问题出现在哪里呢？或者有没有降低延迟的办法呢？[阿里云]
用DTS从RDS MySQL数据库中同步数据到云Kafka中，增量同步数据延迟时间超过1秒，，连链路规格已经large最高的了，Flink怎么诊断问题出现...
使用数据传输DTS从RDS MySQL数据库中同步数据到云Kafka中，怎么诊断问题出现在哪里呢？[阿里云]
使用数据传输DTS从RDS MySQL数据库中同步数据到云Kafka中，增量同步数据延迟时间超过1秒，，连链路规格已经large最高的了，怎么诊断问题...
关于Flink弹性扩缩容有个疑问：缩容同理（释放TM）这种能做到吗？[阿里云]
关于Flink弹性扩缩容有个疑问：比如Kafka12个分区，Flink任务（KafkaSource -> Process -> BDSink）On Yarn application模式，初...
机器学习PAI这个问题怎么解决？[阿里云]
机器学习PAI这个问题怎么解决？利用官方的webui教程，容器搭建了一套，在webui上配置了一个csv到kafka的流程，一直报kafka的factory找不...
flink 消费kafka,之前任务正常的，突然有个分区没法消费了，重启下任务久正常了？[阿里云]
flink 消费kafka,之前任务正常的，突然有个分区没法消费了，重启下任务久正常了？
flink 消费kafka,之前任务正常的，突然有个分区没法消费了，重启下任务久正常了？[阿里云polardb]
flink 消费kafka,之前任务正常的，突然有个分区没法消费了，重启下任务久正常了？