阿里云文档 2025-03-13

如何搭建环境来进行自建Flink作业迁移

在进行自建Flink作业迁移之前,需首先搭建基础环境。本文将为您介绍基础环境的搭建方法。

文章 2022-04-25 来自:开发者社区

Flink能够更方便地升级、迁移、暂停、恢复应用服务

  Flink能够更方便地升级、迁移、暂停、恢复应用服务  驱动关键业务服务的流应用是经常需要维护的。比如需要修复系统漏洞,改进功能,或开发新功能。然而升级一个有状态的流应用并不是简单的事情,因为在我们为了升级一个改进后版本而简单停止当前流应用并重启时,我们还不能丢失掉当前流应用的所处于的状态信息。  而Flink的 Savepoint 服务就是为解决升级服务过程中记录流应用状态信息及其相关难题....

文章 2022-02-09 来自:开发者社区

如何迁移 Flink 任务到实时计算 Flink 版|学习笔记

开发者学堂课程【《实时计算 Flink 版产品入门与实操》:如何迁移 Flink 任务到实时计算 Flink  版】学习笔记,与课程紧密联系,让用户快速学习知识。课程地址:https://developer.aliyun.com/learning/course/334/detail/3742如何迁移 Flink 任务到实时计算 Flink 版内容简介:1.如何迁移,从 flink ru....

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

Flink集群迁移savepoint还会保留原集群地址吗?

本来在Flink集群迁移过程中,使用版本flink 1.6.2,将savepoint进行保存,并迁移到新的hdfs集群的时候,并从该savepoint进行恢复的时候,出现找不到之前hdfs集群信息的错误信息,错误如下: java.lang.Exception: Exception while creating StreamOperatorStateContext. at org....

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

作业从flink1.9.0迁移到1.10.1

LogicalTypeRoot变更后无法从CP恢复:No enum constant org.apache.flink.table.types.logical.LogicalTypeRoot.ANY 各位好:    当我把作业从flink1.9.0迁移到1.10.1,且作业中使用了'group by'形式的语法时,会导致无法从cp/sp恢复, 代码: 报错如下: switche...

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

flink1.9状态及作业迁移

flink1.9的检查点或保存点中会保留hadoop集群的nameservice数据吗?现在想将一个集群的flink作业迁移到另一个集群,但两个集群的nameservice名称不一样,迁移会有问题吗?如果有问题的话对应状态保存的nameservice可以修改吗?或者说迁移的时候还有哪些其他需要注意的问题? *来自志愿者整理的flink邮件归档

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

生产hive sql 迁移flink 11 引擎,碰到的问题

最近尝试把一个生产 hive sql 任务,执行引擎切换成 flink 1.11.2 ,发现flink 11 对hive SQL的支持有下列问题1、不支持 双引号 表示字符串 2、不支持 != 表示不等运算 3、不支持 类型隐式转换 4、不支持 split 函数 5、hive 不区分大小写,flink区分大小写 6、join右表 不支持是一个子查询(Calcite bug  https....

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

Flink savepoint迁移问题

社区各位大佬,我遇到了一个Flink版本升级后,savepoint不会正确恢复问题。 版本从1.9.3 升级到1.11.0或1.11.3. 连接器使用的pulsar的连接器。在Source的checkpoint数据结构如下 oldUnionOffsetStates = stateStore.getUnionListState( new ListStateDescriptor<>( OF...

问答 2021-11-25 来自:开发者社区

如何迁移:从 Flink run 到流计算平台?

如何迁移:从 Flink run 到流计算平台?

文章 2021-09-27 来自:开发者社区

如何迁移开源 Flink 任务到实时计算Flink版?实战手册来帮忙!

作为国内最早布局实时计算技术方向的企业之一,早在2016年阿里巴巴就已经开始大规模上线使用实时计算产品。阿里云实时计算Flink版(Alibaba Cloud Realtime Compute for Apache Flink,Powered by Ververica)是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统,由 Apache Flink 创始团队官方出品,....

如何迁移开源 Flink 任务到实时计算Flink版?实战手册来帮忙!

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

产品推荐

阿里云实时计算Flink

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

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问