实时计算 Flink版
-
Flink Dtaskmanager.memory.process.size 这个参数我随便怎么设?-[阿里云_云淘科技]
Flink Dtaskmanager.memory.process.size 这个参数我随便怎么设?task manager都是至少占用2G内存 以下为热心网友提供的参考意见 Fl…
-
PG库的flink cdc是基于查询的吗?-[阿里云_云淘科技]
PG库的flink cdc是基于查询的吗? 以下为热心网友提供的参考意见 是的,Flink CDC(Change Data Capture,变更数据获取)是一个开源的是的,Flin…
-
flink on yarn的应用模式,我提交一个程序最少都要占用4G内存吗?-[阿里云_云淘科技]
flink on yarn的应用模式,我提交一个程序最少都要占用4G内存吗?task manager占至少2G,job manager占2G。 以下为热心网友提供的参考意见 Fli…
-
Flink有2023 Flink Forward Asia 资料下载地址吗?-[阿里云_云淘科技]
Flink有2023 Flink Forward Asia 资料下载地址吗?
-
使用flink实时写入数据库,并发只能是1,如果并行度加大,就会导致行锁,最后就一直等待?-[阿里云_云淘科技]
使用flink实时写入数据库,并发只能是1,因为同一条记录会出现多次变化,如果并行度加大,就会导致行锁,最后就一直等待? 以下为热心网友提供的参考意见 Flink实时写入数据库并发…
-
Flink sql 大家生产都是怎么运行的,是嵌入java代码中,还是在SQL客户端中运行的?-[阿里云_云淘科技]
Flink sql 大家生产都是怎么运行的,是嵌入java代码中,还是在SQL客户端中运行的? 以下为热心网友提供的参考意见 在生产环境中,运行Flink SQL的方式主要有两种。…
-
flink sql 现在是不是能给算子单独调整并行度了啊?-[阿里云_云淘科技]
flink sql 现在是不是能给算子单独调整并行度了啊? 以下为热心网友提供的参考意见 是的,Flink SQL可以给算子单独调整并行度。具体来说,有两种主要方式可以进行设置: …
-
DataWorks数据同步马上要上flink-cdc了,有没有相关文档可以让我们提前了解和规划下?-[阿里云_云淘科技]
DataWorks数据同步马上要上flink-cdc了,有没有相关文档可以让我们提前了解和规划下?因为公共数据集成资源组也要快下线了,我们到时候都需要整改到独享数据集成资源组,那么…
-
DataWorks独享资源组的配置如何?-[阿里云_云淘科技]
DataWorks独享资源组的配置如何?如果依赖flink-cdc,那么就需要启动flink环境。flink环境所需要的初始配置最起码1cu? 以下为热心网友提供的参考意见 未来同…
-
有人用flink sql同步数据到oracle吗?-[阿里云_云淘科技]
有人用flink sql同步数据到oracle吗?我看官网支持oracle upsert的,我实际写了,执行报错说不支持 以下为热心网友提供的参考意见 这个意思是底层写入的时候会使…
-
有人知道这个format怎么写,能让时间格式变成这样么?-[阿里云_云淘科技]
有人知道这个format怎么写,能让时间格式变成2023-06-08T08:08:08+08:00这样么? 以下为热心网友提供的参考意见 ,此回答整理自钉群“【③群】Apache …
-
本地测试可以正常运行,在flink集群上跑就报这个错误?-[阿里云_云淘科技]
本地测试可以正常运行,在flink集群上跑就报这个错误?是用maven-shade-plugin插件打的,打出来的jar是这样的