PyFlink 在 Flink 1.15 中的“线程”模式带来了哪些性能提升？
PyFlink 在 Flink 1.15 中的“线程”模式带来了哪些性能提升？
实时计算 Flink版产品使用合集之同步MySQL数据到Hologres时，配置线程池的大小该考虑哪些
问题一：Flink的ctas/cdas有开源计划和安排吗？ Flink的ctas/cdas有开源计划和安排吗？ 参考答案： 没有哈 关于本问题的更多回答可点击进行查看： https://developer.aliyun.com/ask/581178 问题二：我要用flink同步mysql数...
实时计算 Flink版操作报错之Apache Flink中的SplitFetcher线程在读取数据时遇到了未预期的情况，该怎么解决
问题一：Flink CDC跑联表任务时候，程序的内存会慢慢增大，这个报错是因为什么呢？ Flink CDC跑联表任务时候，程序的内存会慢慢增大，达到4G左右的时候会突然降到300M,同时jobmanager日志里显示有报错ERROR org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHa...
实时计算 Flink版产品使用合集之实现存量读取时采用多线程、增量读取时采用单线程如何解决
问题一：Flink CDC同一个流中，如何设置存量读取时采用多线程，增量读取时采用单线程呢？ Flink CDC同一个流中，如何设置存量读取时采用多线程，增量读取时采用单线程呢？ 参考回答： Flink CDC 支持多线程并发读取存量数据和单线程读取增量数据。具体来说，可以通过设置不同的并行度来实现。 对于存量数据的读取，可以设置较高的并行度来...
实时计算 Flink版产品使用合集之全量快照是由多个线程同时进行的吗
问题一：Flink CDC中drios整合es中，使用俩表的关联查询，到es中是不是父子文档才行啊？ Flink CDC中drios整合es中，使用俩表的关联查询，到es中是不是父子文档才行啊？ 参考回答： 在Flink CDC中整合Elasticsearch（ES）的过程中，确实需要实现父子文档的关联查询才能实现多张表的关系映射。父子文档是指父文档和...
实时计算 Flink版产品使用合集之mysql通过flink cdc同步数据，有没有办法所有表共用一个dump线程
问题一：如果编译方式对的话，使用jdk17也是可以用flinkcdc的？ 如果编译方式对的话，使用jdk17也是可以用flinkcdc的？jdk8的时候flinkcdc编译不报错 参考回答： 是的，Apache Flink的官方文档明确指出，Flink CDC支持JDK 8、JDK 11和JDK 17。所以，只要你的编译方式正确，你可以使用任何这些版本...
实时计算 Flink版产品使用合集之如何解决 TaskManager和 JobManager中有大量的等待线程
问题一：Flink1.13.6 hadoop3.1.1版本，发现TM、JM中有大量的等待线程，有人遇到过吗？ Flink1.13.6 hadoop3.1.1版本，发现TM、JM中有大量的LeaseRenewer等待线程，有人遇到过吗？ ...
实时计算 Flink版产品使用合集之多线程环境中，遇到 env.addSource 添加数据源后没有执行到 env.execut，是为什么
问题一：Flink这里的业务延迟 是由什么决定的？ Flink这里的业务延迟 是由什么决定的？ 参考回答： Flink的业务延迟（Business Latency）可以由多个因素决定。以下是一些常见...
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。