问答 2023-04-23 来自:开发者社区

请问有知道flink per-job模式怎么运行在指定任务上?

请问有知道flink per-job模式怎么运行在指定任务在某些yarn nodemanager上么(比如yarn集群有十节点,怎么运行在其中五个节点上运行任务)?

问答 2023-04-19 来自:开发者社区

有人知道flink on yarn 的application模式怎么提交多个job组成应用程序呢?

有人知道flink on yarn 的application模式怎么提交多个job组成应用程序呢?

问答 2023-04-19 来自:开发者社区

Flink中报错直接启动不了,进而导致pod里面的JM起不来了,该怎么办呢?

我的部署方式是flink on native k8s,使用application模式。其中,为了对接相关平台,我flink-conf.yaml中配置的jobmanager.rpc.address,没有用原生的servicename.namespace方式,而是使用了servicename直接指定。为此,我改造了flink-1.14.0\flink-kubernetes\src\main\java....

问答 2023-04-19 来自:开发者社区

flink批模式查一张几千万的hive到另一个hive表,一下子起了1000的并行度,怎么降下来?

flink批模式查一张几千万的hive到另一个hive表,一下子起了1000的并行度,怎么降下来?

问答 2023-04-19 来自:开发者社区

flink批模式提高并行度,发现不管怎么调参数,并行度都是1,怎么解决这个问题?

flink批模式提高并行度,发现不管怎么调参数,并行度都是1,怎么解决这个问题?

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

请教一下、flink on yarn模式下如何让提交的Application任务中加载的一些配置文

请教一下、flink on yarn模式下如何让提交的Application任务中加载的一些配置文件及jar包打到hdfs的/user/flink/.flink的目录下

问答 2023-04-10 来自:开发者社区

flink集群application模式有人遇到过这个问题吗?

flink集群application模式有人遇到过这个问题吗?

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

flink cdc oracle 最新版本支持无锁模式了吗?

flink cdc oracle 最新版本支持无锁模式了吗?

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

请问一下,我已经使用Flink的SQL Client通过JDBC连接模式将数据从SQL Server

请问一下,我已经使用Flink的SQL Client通过JDBC连接模式将数据从SQL Server导入到Hudi表中 然后将数据从hudi导入到SQL Server另一个表中 报错 Loading class com.mysql.jdbc.Driver'. This is deprecated. The new driver class iscom.mysql.cj.jdbc.Driver'.....

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

flink cdc initial 模式, source表数据量过大,导致checkpoint

flink cdc initial 模式, source表数据量过大,导致checkpoint 一直 Checkpoint expired before completing. 有没有遇到过的大神指导一下如何优化呀?

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

产品推荐

实时计算 Flink

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

+关注