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

问下flink sql 创建的任务 flink重启后表丢失这个生产是怎么弄的啊?

问下flink sql 创建的任务 flink重启后表丢失这个生产是怎么弄的啊?还有任务执行信息的保存这些flink集群重启保存怎么设置的啊?

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

Flink这个C2compiler有办法优化性能吗?1.15.1版本flink sql的任务

Flink这个C2compiler有办法优化性能吗?1.15.1版本flink sql的任务

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

目前用flink oracle cdc sql,任务无报错,但是没有数据输出,为什么?

目前用flink oracle cdc sql,任务启动运行正常,无报错,但是select * from 表名, 就是没有数据输出,有没有大佬可以指点一下?

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

我想问问:flink sql提交的任务如何持久化,即当flink集群遭遇异常重启后,能够 自动 按c

我想问问:flink sql提交的任务如何持久化,即当flink集群遭遇异常重启后,能够 自动 按checkpoint或savepoint恢复以前的执行任务?flink配置能实现吗?

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

当前版本的Flink Mysql CDC, 支持动态更改SQL任务吗?

当前版本的Flink Mysql CDC, 支持动态更改SQL任务吗,Mysql 数据组装写入ES时想要动态新增字段,重新提交flink 初始化数据的时间开销太大了,总共需要向写入ES数据2千万条数据

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

表格存储三个flink sql 往任务往tablestore 同一张表写入数据,为什么数据覆盖掉了?

表格存储三个flink sql 往任务往tablestore 同一张表写入数据,有三个任务,为什么数据最后覆盖掉了?没有进行upsert的操作了,三个任务插入的字段各不一样

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

如果用flink sql提交同步任务,这种方式是读取binglog日志实现同步数据到目标库中的吗?

如果用flink sql提交同步任务,这种方式是读取binglog日志实现同步数据到目标库中的吗

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

Flink CDC 在sql-client提交任务的话,--allowNonRestoredSta

Flink CDC 在sql-client提交任务的话,--allowNonRestoredState 这个参数怎么用啊?

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

flink刚启动时通过sql创建任务时数据能复制到es,然后mongo里的数据就没了,再添加es也不

flink刚启动时通过sql创建任务时数据能复制到es,然后mongo里的数据就没了,再添加es也不同步cdc模拟一个mongo节点,是不是应该通过rs.status能查以呢?我查着还是一个主节点,没有子节点,是不是监听有问题啊

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

flink sql任务提交后,task manager memory 一直打满

flink 任务提交后,task manager memory 一直打满,修改并行度和增大task managered 的内存,再次提交,仍然是打满的,运行一段时间后(1~2小时),然后报一下错误: 业务场景是,flink mysql cdc 监控任务左表的数据,通过jdbc对维表做lookup join,开启了rocksDB

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

产品推荐

数据库

分享数据库前沿,解构实战干货,推动数据库技术变革

+关注