前言 Kyuubi 1.9.2 on Yarn模式官方支持Spark、Flink和Hive引擎。本片分别介绍它们的部署方式。 环境信息 Kyuubi 1.9.2 Spark ...
发简信
IP属地：山西
-
Kyuubi Spark Flink Hive 引擎使用
-
基于Kafka+Flink+Redis的电商大屏实时计算案例前言 一年一度的双11又要到了，阿里的双11销量大屏可以说是一道特殊的风景线。实时大屏（real-time dashboard）正在被越来越多的企业采用，用来及时呈现关键的数...
-
Flink SQL空闲状态保留时间（idle state retention time）实现原理前言 如果要列举Flink SQL新手有可能犯的错误，笔者认为其中之一就是忘记设置空闲状态保留时间导致状态爆炸。2021年的第一篇技术文，时间很紧张，聊聊这个简单的话题吧。 ...
-
Flink on Zeppelin问题四则（并没有优雅的解决方案前言 最近我们正式调研Zeppelin作为Flink SQL开发套件的可能性，于是clone了最新的Zeppelin v0.10-SNAPSHOT源码，自行编译并部署到了预发...
-
关于有状态Flink作业改变Kafka Consumer UID后位点跳变到EARLIEST这档事前言 这是很多Flink用户不太注意的一个隐藏得比较深的坑（严格来讲不算bug），近期组内同学频繁踩坑，故十分有必要快速记录一下，以提请注意。 复现问题 用户意图：将有状态F...
-
Flink SQL 如何实现列转行 ?
在 SQL 任务里面经常会遇到一列转多行的需求,下面就来总结一下在 Flink SQL 里面如何实现列转行的,先来看下面的一个具体案例. 需求 原始数据格式如下: named...
-
2024总结
前言 今年是我工作的第十个年头，也是第十篇年度总结。按照惯例，对这一年的经历进行回顾，总结所学和所得。希望我的思考能对你有所启发。 工作 人常说，不怕达不成目标，就怕没有目标...
-
Flink 源码之异步state API
Flink源码分析系列文档目录 请点击：Flink 源码分析系列文档目录[https://www.jianshu.com/p/d4a372809e3d] 前言 Flink 2...
-
Flink RocksDB状态缩放加速：RocksDB原生DeleteRange原理简析又见Rescale 笔者在很久之前的一篇文章（传送门[https://www.jianshu.com/p/f0a13f98dac2]）中讲解过Flink的状态缩放（Resca...
