文章 2024-08-26 来自:开发者社区

Flink 新一代流计算和容错问题之 Flink 作业的 local buffer pool 的 size 要如何估算

问题一:Flink 哪个版本开始支持 Unaligned Checkpoint? Flink 哪个版本开始支持 Unaligned Checkpoint? 参考回答: Flink 从 1.11 版本开始支持 Unaligned Checkpoint。 ...

Flink 新一代流计算和容错问题之 Flink 作业的 local buffer pool 的 size 要如何估算
问答 2024-07-29 来自:开发者社区

如何估算 Flink 作业的 local buffer pool 的 size?

如何估算 Flink 作业的 local buffer pool 的 size?

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

Flink报错ErrorCode=Local Error, ErrorMessage=Fail...

Flink报错ErrorCode=Local Error, ErrorMessage=Failed to create upload session with tunnel endpoint

问答 2024-05-30 来自:开发者社区

Flink报错flink row type: TIMESTAMP(6) WITH LOCAL ...

Flink报错flink row type: TIMESTAMP(6) WITH LOCAL TIME ZONE, hologres type: timestamp

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

实时计算 Flink版产品使用合集之本地local模式下断点续传可以操作吗

问题一:Flink CDC本地调试,是不是启动的时候不会用chekpoint恢复,这种加上参数才行呢? Flink CDC本地调试,是不是启动的时候不会用chekpoint恢复,需要像 这种加上参数才行呢 ...

实时计算 Flink版产品使用合集之本地local模式下断点续传可以操作吗
文章 2023-11-08 来自:开发者社区

在Flink CDC中,本地模式(Local Mode)是指Flink任务在单个节点上运行

在Flink CDC中,本地模式(Local Mode)是指Flink任务在单个节点上运行,不启用任务并行度,所有算子都在一个线程中执行。在这种模式下,Flink CDC可以实现断点续传。 具体来说,你可以通过以下步骤来实现断点续传: 在全量同步开始前,记录同步位置。这可...

问答 2023-11-06 来自:开发者社区

Flink CDC本地local模式。断点续传可以操作吗?

Flink CDC本地local模式。断点续传可以操作吗?

问答 2022-12-27 来自:开发者社区

问个问题,flink run as local 是不是没有webui端口?不是startCluste

问个问题,flink run as local 是不是没有webui端口?不是startCluster方式,而是jar 运行时,run -t local 方式运行

问答 2022-07-03 来自:开发者社区

flink application模式,现在是只支持local://xx.jar吗,支持hdfs:/

flink application模式,现在是只支持local://xx.jar吗,支持hdfs://xxx.jar吗

问答 2021-12-07 来自:开发者社区

flink 1.11 local execution oom问题

我在使用1.11版本在本地idea起一个作业时,并发为1,抛出了如下关于内存的异常。。问题是之前从来没有显示配置过taskmanager的memory参数,这是为何? 感觉由1.10升级到1.11问题还是挺多的。。我尝试增加了JVM参数,增加DirectMemory内存配置,还是没有作用,请教大神帮忙看下。 Exception in thread "main" java.lang.OutOfM.....

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注