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

现在Flink CDC CDC的最新版 StartupOptions.timestamp模式时 是不

现在Flink CDC CDC的最新版 StartupOptions.timestamp模式时 是不是还不支持表名带下划线?

文章 2022-12-01 来自:开发者社区

flink 单作业模式部署提交作业爆:Trying to access closed classloader. Please check if you store classloaders direc

指令信息.flink run -d -t yarn-per-job -c my.test.FlinkaStreamTest My-test-1.0-SNAPSHOT.jar报错信息:Exception in thread “Thread-5” java.lang.IllegalStateException: Trying to access closed classloader. Please ....

flink 单作业模式部署提交作业爆:Trying to access closed classloader. Please check if you store classloaders direc
问答 2022-11-27 来自:开发者社区

一直不知道flink cdc自动同步模式变更是如何操作的,有操作方法吗?

一直不知道flink cdc自动同步模式变更是如何操作的,有操作方法吗?

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

请教下,flink-cdc 2.30使用时间戳模式去监听mysql,对mysql是不是有版本限制,目

请教下,flink-cdc 2.30使用时间戳模式去监听mysql,对mysql是不是有版本限制,目前我监听mysql-5.7.35-log是正常的,监听5.7.37-log没用任何反应

问答 2022-11-22 来自:开发者社区

请教大家个问题,flink 增量checkpoint, 如果是yarn per-job模式起任务,任

请教大家个问题,flink 增量checkpoint, 如果是yarn per-job模式起任务,任务挂掉了,后面手动指定上一次checkpoint启动任务 ,state是完整的吗?我理解的是增量 checkpoint 仅包含上次 checkpoint 和本次 checkpoint 之间状态的差异,手动指定的只是这个差异部分,并不是完整的checkpoint,是吗?

问答 2022-11-13 来自:开发者社区

请教个问题,用flink读本地文件可以得到输出结果,但是提交到flink单机模式服务器上执行jar包

请教个问题,用flink读本地文件可以得到输出结果,但是提交到flink单机模式服务器上执行jar包就看不到输出结果,任务2秒就结束了,也没有报错日志,有大神知道是什么原因吗?本地的执行结果

问答 2022-11-13 来自:开发者社区

flink 1.14.3 run on k8s,application模式,更新升级代码时,如果删除

flink 1.14.3 run on k8s,application模式,更新升级代码时,如果删除deployment,不删除configmaps,则代码执行逻辑还是旧的,不会更新;如果删除deployment和configmaps,则代码会更新,但是却无法从checkpoint恢复,因为从那个checkpoint恢复写在configmap中,请教大佬如何在代码逻辑更新升级时如何保留confi....

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

Flink实际集群部署Standalone模式

1.三台机器 配置免密登录,主机名环境 jdk1.8一主两从2.tar -zxvf ...........cd conf vi flink-conf.yaml jobmanager.rpc.address: hadoop1 vi slaves hadoop2 hadoop33.拷贝修改的文件scp -rq flink-1.6.1 hadoop2:$PWDscp -rq flink-1.6.1 h....

问答 2022-10-30 来自:开发者社区

flink1.15启动standalone模式集群,一直提示 UnsupportedFileSyst

flink1.15启动standalone模式集群,一直提示 UnsupportedFileSystemSchemeException: Hadoop is not in the classpath/dependencies.

问答 2022-10-30 来自:开发者社区

Flink On Yarn模式,有办法可以固定jobmanager.rpc.port端口吗?

Flink On Yarn模式,有办法可以固定jobmanager.rpc.port端口吗?

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

产品推荐

实时计算 Flink

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

+关注