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执行CREATE TABLE AS(CTAS)语句报错这个错,怎么解决?[阿里云]
Flink执行CREATE TABLE AS(CTAS)语句报错这个错,怎么解决?说这个表中kafka catalog中不存在,就是想执行这个语句创建这个表 以下为...
数据传输DTS这个错是啥问题啊?[阿里云]
数据传输DTS这个错是啥问题啊?2023-12-22 19:25:05 以下为热心网友提供的参考意见 单看报错是需要调大客户端default.api.timeout.ms参...
请教下数据传输DTS订阅数据变更消息,client启动时报这个错误是什么原因?[阿里云]
请教下数据传输DTS订阅数据变更消息,client启动时报这个错误是什么原因?订阅配置检查过都没有问题。2023-12-21 12:10:09.816 INFO 770...
关于Flink弹性扩缩容有个疑问:缩容同理(释放TM)这种能做到吗?[阿里云]
关于Flink弹性扩缩容有个疑问:比如Kafka12个分区,Flink任务(KafkaSource -> Process -> BDSink)On Yarn application模式,初...
机器学习PAI这个问题怎么解决?[阿里云]
机器学习PAI这个问题怎么解决?利用官方的webui教程,容器搭建了一套,在webui上配置了一个csv到kafka的流程,一直报kafka的factory找不...
flink 消费kafka,之前任务正常的,突然有个分区没法消费了,重启下任务久正常了?[阿里云polardb]
flink 消费kafka,之前任务正常的,突然有个分区没法消费了,重启下任务久正常了?
flink 消费kafka,之前任务正常的,突然有个分区没法消费了,重启下任务久正常了?[阿里云]
flink 消费kafka,之前任务正常的,突然有个分区没法消费了,重启下任务久正常了?
数据传输DTS网络抖动等原因导致当前数据写入模块连接缓存模块超时?[阿里云polardb]
数据传输DTS网络抖动等原因导致当前数据写入模块连接缓存模块超时?【UID】:30480957【Job ID】:ztb128cpa4l782f【任务名称】:dtsglx...