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

实时计算 Flink版产品使用问题之在YARN集群上运行时,如何查看每个并行度的详细处理数据情况

问题一:根据官网的文档,是使用flink+holo 还是flink+paimon更好呀,更节约成本? 我这边的业务场景是需要把用户点击到下单完成的整个业务串起来,形成一个业务宽表,时延5分钟左右,根据官网的文档,是使用flink+holo 还是flink+paimon更好呀,更节约成本? 参考答案: 后者 更节约成本 关于...

实时计算 Flink版产品使用问题之在YARN集群上运行时,如何查看每个并行度的详细处理数据情况
问答 2024-05-14 来自:开发者社区

Flink Task,运行时只能通过每个 Task 的 UI Port 来查看当前任务吗?

在 docker 上部署 Flink Task,以 Applicaiton Mode 运行时只能通过每个 Task 的 UI Port 来查看当前任务吗?

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

Flink CDC里这个参数直接放在conf文件吗?1.17之前的还是直接运行时配参吗?

Flink CDC里env.java.opts.all: -Dfile.encoding=UTF-8这个参数直接放在conf文件吗?1.17之前的还是直接运行时配参吗?

文章 2023-12-29 来自:开发者社区

Flink 运行时日志分析

1.taskmanager 2.taskmanager.loglog.info、debug、error 日志都打到这个里面 3.taskmanager.erre.printStackTrace(); 4.taskmanager.outSystem.out.println("========111111==========");

Flink 运行时日志分析
问答 2023-12-11 来自:开发者社区

Flink CDC是想着测试一下mongocdc, 运行时报错?

Flink CDC是想着测试一下mongocdc, 运行时报错?maven目前导入的所有依赖,maven 依赖冲突检测

文章 2023-12-06 来自:开发者社区

Flink(三)【运行时架构】

前言        今天学习 Flink 的一些原理性的东西,比较偏概念,但是十分重要。有人觉得上来框框敲代码才能学到东西,那是狗屁不通的道理(虽然我以前也这么认为)。个人认为,学习 JavaEE那些框架,你上来就敲代码确实也可以,没有太多难理解的东西;但是对于大数据、分布式包括我们学的很多计算机原理、计算机网络这种理论性强的学科,了解原理是十分有必要的,....

Flink(三)【运行时架构】
问答 2023-10-31 来自:开发者社区

Flink CDC在业务系统中运行时动态创建一个flinkjob提交到flink集群,有实现过吗?

Flink CDC在业务系统中运行时动态创建一个flinkjob提交到flink集群,有大神实现过吗?我只是想在业务系统中屏蔽一些同步操作的复杂度,能够让写业务的同学专心写业务就好了,同步操作通过注解的方式,动态创建job,自动运行

文章 2023-10-11 来自:开发者社区

Fink--3、Flink运行时架构(并行度、算子链、任务槽、作业提交流程)

1、系统架构(以Standalone会话模式为例)1、作业管理器(JobManager)JobManager是一个Flink集群中任务管理和调度的核心,是控制应用执行的主进程。也就是说,每个应用都应该被唯一的JobManager所控制执行。JobManager又包含三个不同的组件(1)JobMasterJobMaster是JobManager中最核心的组件,负责处理单独的作业(Job)。所以Jo....

Fink--3、Flink运行时架构(并行度、算子链、任务槽、作业提交流程)
问答 2023-09-13 来自:开发者社区

oracle库,Flink CDC 版本1.17.0,本地运行时,未设置并行度为1时,有谁遇到过?

oracle库,Flink CDC 版本1.17.0, oracle-cdc版本2.4.1,本地运行时,未设置并行度为1时,增量同步失败你们有谁遇到过么

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

Flink运行一个任务,本地连接远程数据库进行运行时没有问题的,但是部署到服务器后,报错,为什么?

Flink运行一个任务,本地连接远程数据库进行运行时没有问题的,但是部署到服务器后,运行同样的任务,报错,查看版本都是flink 1.13版本,Flink报错是为什么?

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

产品推荐

阿里云实时计算Flink

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

+关注