问答 2022-08-01 来自:开发者社区

各位大佬,请教一下flink该怎么sink到阿里oss中,有没有demo?谢谢

各位大佬,请教一下flink该怎么sink到阿里oss中,有没有demo?谢谢

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

请问一下,flink 能采用jindodata写入oss?

请问一下,flink 能采用jindodata写入oss?

高性能

Flink CDC 实现企业级实时数据同步

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 Flink CDC 技术实现了统一的增量和全量数据的实时集成。
技术解决方案背景图
问答 2022-03-25 来自:开发者社区

通过云速搭部署 Flink 应用时,如何配置oss资源参数?

通过云速搭部署 Flink 应用时,如何配置oss资源参数?

文章 2021-12-19 来自:开发者社区

Flink 高效 sink 写入 oss | 学习笔记

开发者学堂课程【数据湖 JindoFS + OSS 实操干货36讲:Flink 高效 sink 写入 oss】学习笔记,与课程紧密联系,让用户快速学习知识。课程地址:https://developer.aliyun.com/learning/course/833/detail/13967Flink 高效 sink 写入 oss 内容介绍一.背景介绍二.功能介绍三.如何配置四.如何使用 ....

Flink 高效 sink 写入 oss | 学习笔记
问答 2021-12-09 来自:开发者社区

支持Flink可恢复性写入JindoFS或OSS的版本是什么?

支持Flink可恢复性写入JindoFS或OSS的版本是什么?

问答 2021-12-08 来自:开发者社区

flink访问多个oss bucket问题

flink平台作业写数据到客户oss bucket,和flink平台作业本身做checkpoint/savepoint用的oss bucket不是同一个。 请问这种场景flink是否支持,如果支持的话应该要怎么配置?谢谢!*来自志愿者整理的flink

问答 2021-12-02 来自:开发者社区

flink 以阿里云 oss 作为 checkpoint cpu 过高怎么处理?

flink 程序以 RocksDB 作为 stateBackend, aliyun OSS 作为 checkpoint 数据最终的物理位置。 我们的监控发现节点 cpu 间隔性地变高,这个间隔时间恰好就是程序的 checkpoint 时间间隔。 [image: image.png] 这个可能的原因是什么?会跟 OSS 有关吗?*来自志愿者整理的flink邮件归档

问答 2021-12-02 来自:开发者社区

flink sink oss problem

当我使用 https://github.com/apache/flink/pull/7798, 这个PR打pacth到flink 1.11.2,发现写flink通过Datastream写OSS功能并不可用。 报错信息如下: java.lang.RuntimeException: java.lang.RuntimeException: class org.apache.hadoop.securit....

问答 2021-12-02 来自:开发者社区

flink作业日志能否保存到oss?

我们使用k8s运行flink作业,作业日志存储在容器中,一旦作业挂了容器销毁了就没法获取出问题的日志,有什么办法可以将日志保存到oss上么?通过配置启动history server吗?*来自志愿者整理的flink邮件归档

问答 2021-12-02 来自:开发者社区

Flink RocksDBStateBackend 可以设置阿里云 OSS 存储吗?

如题, 可以直接这样写吗? env.setStateBackend(new RocksDBStateBackend(“oss://”, true));*来自志愿者整理的flink邮件归档

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

产品推荐

阿里云实时计算Flink

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

+关注