问答 2024-07-24 来自:开发者社区

有使用zeppelin连接阿里全托管的flink的吗? 非EMR-flink

有使用zeppelin连接阿里全托管的flink的吗? 非EMR-flink

问答 2023-11-06 来自:开发者社区

有用 flink on zeppelin的吗?

有用 flink on zeppelin的吗?

阿里云文档 2023-09-03

如何在Zeppelin中使用Flink_EMR on ECS_开源大数据平台 E-MapReduce(EMR)

Flink是流式计算引擎。本文为您介绍如何在Zeppelin中使用Flink。

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

请问一下,有没有人用过zeppelin的,都是怎么支持flink 1.15.0。。

请问一下,有没有人用过zeppelin的,都是怎么支持flink 1.15.0。。

文章 2022-06-07 来自:开发者社区

Flink on zeppelin从checkpoint&savepoint自动恢复任务​

在上一篇的文章中介绍了Flink on zeppelin怎么配置checkpoint,并且从指定的checkpoint恢复任务,但是这个过程还是相对复杂,对用户来说不是很友好,在最新的版本中,zeppelin支持了自动从checkpoint&savepoint恢复任务,只需要添加几个参数即可,下面就来介绍一下如何使用.1.checkpoint自动恢复1.1 指定checkpoint恢复先....

Flink on zeppelin从checkpoint&savepoint自动恢复任务​
文章 2022-06-07 来自:开发者社区

Flink on zeppelin第五弹设置checkpoint

概述Flink的exactly-once语义实现是需要依赖checkpoint的,对于一个有状态的Flink任务来说如果想要在任务发生failover,或者手动重启任务的时候任务的状态不丢失是必须要开启checkpoint的,今天这篇文章主要分享一下Flink on zeppelin里面怎么设置checkpoint以及怎么从指定的checkpoint恢复任务.checkpoint配置%flink....

Flink on zeppelin第五弹设置checkpoint
文章 2022-06-07 来自:开发者社区

Flink on zeppelin 实时写入hive

概述随着Flink1.11.0版本的发布,一个很重要的特性就是支持了流数据直接写入到hive中,用户可以非常方便的用SQL的方式把kafka的数据直接写入到hive里面.这篇文章会给出Flink on zeppelin里面实现流式写入hive的简单示例以及遇到问题的解决方案Streaming Writing先来看一下官网对hive streaming writing的介绍.streaming w....

Flink on zeppelin 实时写入hive
文章 2022-06-07 来自:开发者社区

Flink on zeppelin第三弹UDF的使用

用户自定义函数是非常重要的一个特征,因为它极大地扩展了查询的表达能力。不管是在spark sql或者hive中都支持用户自定义UDF的使用,虽然Flink提供了很多内置的UDF可以直接使用,但是一些特定的场景可能需要我们自定义UDF去实现,这篇文章会主要介绍一下在Flink on zeppelin里面使用UDF的3种方法.1, 开发scala代码并注册UDF因为目前zeppelin支持Scala....

Flink on zeppelin第三弹UDF的使用
文章 2022-06-07 来自:开发者社区

Flink on zeppelin 结合kafka实时计算pv uv写入mysql

上一篇文章主要介绍了Flink on zeppelin的安装和使用,配置了yarn的模式跑通了一个streaming wordcount的例子,本文主要介绍结合kafka的使用,实时计算一个简单的pv,uv把结果写入到mysql的例子.添加依赖包首先需要添加kafka以及mysql的jar包,有两种方式,第一种是直接把jar包添加到Flink的lib下面,如下所示:只需要添加 flink-sql....

Flink on zeppelin 结合kafka实时计算pv uv写入mysql
文章 2022-01-10 来自:开发者社区

Windows下使用zeppelin、Dockers搭建Flink学习环境

一、原因最近在学Flink,学的时候非常怀念学习Python用的Jupyter notebook,因此非常希望也能有一个类似Jupyter Notebook的环境来运行、学习Flink。可惜Jupyter Notebook现在不支持Flink,不过幸好还有Zeppelin。zeppelin是一个基于web的notebook,支持各种解析器,可视化的数据提取,数据发现,数据分析等。当前zeppel....

Windows下使用zeppelin、Dockers搭建Flink学习环境

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

产品推荐

实时计算 Flink

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

+关注
AI助理

你好,我是AI助理

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