问答 2024-06-09 来自:开发者社区

Flink Reporter是有专门的线程吗

Flink Reporter是有专门的线程吗

文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之同步MySQL数据到Hologres时,配置线程池的大小该考虑哪些

问题一:Flink的ctas/cdas有开源计划和安排吗? Flink的ctas/cdas有开源计划和安排吗? 参考答案: 没有哈 关于本问题的更多回答可点击进行查看: https://developer.aliyun.com/ask/581178 问题二:我要用flink同步mysql数...

实时计算 Flink版产品使用合集之同步MySQL数据到Hologres时,配置线程池的大小该考虑哪些
文章 2024-05-23 来自:开发者社区

实时计算 Flink版操作报错之Apache Flink中的SplitFetcher线程在读取数据时遇到了未预期的情况,该怎么解决

问题一:Flink CDC跑联表任务时候,程序的内存会慢慢增大,这个报错是因为什么呢? Flink CDC跑联表任务时候,程序的内存会慢慢增大,达到4G左右的时候会突然降到300M,同时jobmanager日志里显示有报错ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHa...

实时计算 Flink版操作报错之Apache Flink中的SplitFetcher线程在读取数据时遇到了未预期的情况,该怎么解决
文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之实现存量读取时采用多线程、增量读取时采用单线程如何解决

问题一:Flink CDC同一个流中,如何设置存量读取时采用多线程,增量读取时采用单线程呢? Flink CDC同一个流中,如何设置存量读取时采用多线程,增量读取时采用单线程呢? 参考回答: Flink CDC 支持多线程并发读取存量数据和单线程读取增量数据。具体来说,可以通过设置不同的并行度来实现。 对于存量数据的读取,可以设置较高的并行度来...

实时计算 Flink版产品使用合集之实现存量读取时采用多线程、增量读取时采用单线程如何解决
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之全量快照是由多个线程同时进行的吗

问题一:Flink CDC中drios整合es中,使用俩表的关联查询,到es中是不是父子文档才行啊? Flink CDC中drios整合es中,使用俩表的关联查询,到es中是不是父子文档才行啊? 参考回答: 在Flink CDC中整合Elasticsearch(ES)的过程中,确实需要实现父子文档的关联查询才能实现多张表的关系映射。父子文档是指父文档和...

实时计算 Flink版产品使用合集之全量快照是由多个线程同时进行的吗
文章 2024-05-17 来自:开发者社区

实时计算 Flink版产品使用合集之mysql通过flink cdc同步数据,有没有办法所有表共用一个dump线程

问题一:如果编译方式对的话,使用jdk17也是可以用flinkcdc的? 如果编译方式对的话,使用jdk17也是可以用flinkcdc的?jdk8的时候flinkcdc编译不报错 参考回答: 是的,Apache Flink的官方文档明确指出,Flink CDC支持JDK 8、JDK 11和JDK 17。所以,只要你的编译方式正确,你可以使用任何这些版本...

实时计算 Flink版产品使用合集之mysql通过flink cdc同步数据,有没有办法所有表共用一个dump线程
文章 2024-05-16 来自:开发者社区

实时计算 Flink版产品使用合集之如何解决 TaskManager和 JobManager中有大量的等待线程

问题一:Flink1.13.6 hadoop3.1.1版本,发现TM、JM中有大量的等待线程,有人遇到过吗? Flink1.13.6 hadoop3.1.1版本,发现TM、JM中有大量的LeaseRenewer等待线程,有人遇到过吗? ...

实时计算 Flink版产品使用合集之如何解决 TaskManager和 JobManager中有大量的等待线程
文章 2024-05-16 来自:开发者社区

实时计算 Flink版产品使用合集之多线程环境中,遇到 env.addSource 添加数据源后没有执行到 env.execut,是为什么

问题一:Flink这里的业务延迟 是由什么决定的? Flink这里的业务延迟 是由什么决定的? 参考回答: Flink的业务延迟(Business Latency)可以由多个因素决定。以下是一些常见...

实时计算 Flink版产品使用合集之多线程环境中,遇到 env.addSource 添加数据源后没有执行到 env.execut,是为什么
问答 2024-03-11 来自:开发者社区

Flink CDC 里现在增量阶段也只是单线程嘛?

Flink CDC 里现在增量阶段也只是单线程嘛?

问答 2024-03-11 来自:开发者社区

Flink CDC 里单变化的部分写不进目标表。可以在flink上多线程启动怎么做?

Flink CDC 里用StreamTableEnvironment tenv .excutesql 运行 flink sql 开启 scan.incremental.snapshot.enabled = true 的时候, oracle cdc 仍然只能单线程单线程运行,多线程运行时无法写入目标表, 文档上说,开启他就支持多线程?设置了setparall。单写进Java里就出现能多线程启动...

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