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

在一个flink任务中需要近1小时和近6小时的特征,这种在生产上一般用事件时间还是处理时间?

在一个flink任务中需要近1小时和近6小时的特征,这种在生产上一般用事件时间还是处理时间?如果用事件的话,事件窗口可能不关闭怎么办?

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

提交 flink 任务给 k8s 可以在本地推送到服务器吗 ?

提交 flink 任务给 k8s 可以在本地推送到服务器吗 ?还是一定要在服务器操作

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

Flink向k8s 提交任务时能指定 k8s 集群地址吗?

Flink向k8s 提交任务时能指定 k8s 集群地址吗?我找官网的配置参数 没找到有这个配置项

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

Flink CDC提交任务可以指定第三方的jar包么? 则呢么使用昂?

"Flink CDC提交任务可以指定第三方的jar包么? 根据官网的一个参数好像没生效?这俩参数都试过了,没生效~"

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

Flink CDC中flink sql 可以做mysql to mysql同步任务吗?

Flink CDC中flink sql 可以做mysql to mysql同步任务吗?

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

Flink CDC中Oracle19C Cdc调通了,为啥表发生变化,任务运行中为啥捕获不到?

Flink CDC中Oracle19C Cdc调通了,为啥表发生变化,任务运行中为啥捕获不到?重启程序就会把表里所有数据都捕获到,后面新增的,删除的,更新一概没反应,是参数设置问题?

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

Flink CDC发现 starrocks 的插件一个日期处理的函数, 导致 job任务失败,为啥?

Flink CDC发现 starrocks 的插件一个日期处理的函数, 经常抛出异常, 导致 job任务失败?023-12-21 11:11:09,599 WARN org.apache.flink.runtime.taskmanager.Task [] - PostPartition -> Sink Writer: StarRocks Sink -> S...

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

Flink CDC用timestamp模式启动的cdc任务,然后没有采集数据,tm日志一直打印这个?

Flink CDC用timestamp模式启动的cdc任务,然后没有采集数据,tm日志一直打印这个?

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

Flink CDC实时同步的任务一般也是放到yarn中执行吗?

Flink CDC实时同步的任务一般也是放到yarn中执行吗?

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

Flink CDC中timestamp模式启动任务,然后日志一直输出这个是啥问题呀?

Flink CDC中timestamp模式启动任务,然后日志一直输出这个是啥问题呀?

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

产品推荐

阿里云实时计算Flink

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

+关注