问答 2023-12-31 来自:开发者社区

dataworks可以建flink任务吗?

dataworks可以建flink任务吗?

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

Flink 异步IO优化任务

1.通过监控,发现操作耗时,hbase get 操作耗时在10-20ms,高的时候能达到40-50ms,低的时候10ms以内 2.解决方案采用flink 异步io 优化代码final long timeout = 40000; AsyncFunction<String, String> function = new AlbumAsyncFunction(); DataStream&am...

Flink 异步IO优化任务
问答 2023-12-28 来自:开发者社区

flink任务一直报错,怎么解决?

flink任务一直报错,怎么解决?我尝试定位了一下问题,我把taskmanager.host改为localhost后,这里就可以正常运行了,但是这里会显示localhost点灯,我不确定是不是akka通信出了问题,ip地址应该没有问题,因为slot、cpu等显示都是正常的。

问答 2023-12-25 来自:开发者社区

Flink k8s 上的 application 模式提交的任务 日志该怎么处理啊?

Flink k8s 上的 application 模式提交的任务 日志该怎么处理啊?

问答 2023-12-25 来自:开发者社区

想对Flink提交到k8s上的任务进行savepoint保存。报超时的错误,如下图。请问如何解决呀?

想对Flink提交到k8s上的任务进行savepoint保存。报超时的错误,如下图。请问如何解决呀?运行语句是: ./bin/flink stop --savepointPath /tmp/flink-savepoints \d99825def28c408948dc699699c038bd

问答 2023-12-25 来自:开发者社区

在一个flink任务中需要近1小时和近6小时的特征,这种在生产上一般用事件时间还是处理时间?

在一个flink任务中需要近1小时和近6小时的特征,这种在生产上一般用事件时间还是处理时间?如果用事件的话,事件窗口可能不关闭怎么办?

问答 2023-12-25 来自:开发者社区

提交 flink 任务给 k8s 可以在本地推送到服务器吗 ?

提交 flink 任务给 k8s 可以在本地推送到服务器吗 ?还是一定要在服务器操作

问答 2023-12-25 来自:开发者社区

Flink向k8s 提交任务时能指定 k8s 集群地址吗?

Flink向k8s 提交任务时能指定 k8s 集群地址吗?我找官网的配置参数 没找到有这个配置项

问答 2023-12-25 来自:开发者社区

Flink CDC提交任务可以指定第三方的jar包么? 则呢么使用昂?

"Flink CDC提交任务可以指定第三方的jar包么? 根据官网的一个参数好像没生效?这俩参数都试过了,没生效~"

问答 2023-12-25 来自:开发者社区

Flink CDC中flink sql 可以做mysql to mysql同步任务吗?

Flink CDC中flink sql 可以做mysql to mysql同步任务吗?

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

产品推荐

阿里云实时计算Flink

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

+关注