发简信
IP属地：上海
-
取决于提交 Job 的模式是 Single Job 还是 Long Running Cluster
Apache Flink源码解析 （三）Flink On Yarn (1) YarnSessionClusterEntrypoint
杂谈 有一段时间没有写技术博客了，正好之前花了一周的时间解决了一个Flink在Yarn上部署的问题，也将Flink在Yarn上运行的机制与源码了解了个大概。Flink在Yar...
-
ResourceManagerOptions 代码里有
Flink任务物理内存溢出问题定位
问题现象 一个使用10秒滚动窗口的任务在平稳运行一段时间之后出现了频繁的重启。在TaskManager日志中能看到以下文本： 原因定位 首先可以看到是YarnTaskExec...
-
大佬这篇要火
一文详解分布式数据库并发控制
??并发控制是数据库系统实现的一个难点。本文分为三个部分对目前的分布式并发控制技术进行浅析。一、从用户并发访问可能引起的各种问题入手，引出数据库系统提供的不同隔离级别及其技术...
-
一文详解分布式数据库并发控制??并发控制是数据库系统实现的一个难点。本文分为三个部分对目前的分布式并发控制技术进行浅析。一、从用户并发访问可能引起的各种问题入手，引出数据库系统提供的不同隔离级别及其技术...
-
把一个流抽象成一张表的的话，在这张表上做事务操作，要求这张表的状态都在同一个节点，不然会涉及到分布式的事务
关于流数据上的事务操作
概述 最近Flink母公司Data Artisans发布了一篇博客关于一个新的组件Streaming Ledger，给出了流数据的事务解决方案（就是常说的数据库的事务，满足A...
-
-
Flink timer注册与watermark触发[转载自网易云音乐实时计算平台经典实践知乎专栏]经作者magina本人同意，转载自原文在flink中无论是windowOperator还是KeyedProcessOperator都持有InternalTimerServic...
-
-
Flink任务物理内存溢出问题定位问题现象 一个使用10秒滚动窗口的任务在平稳运行一段时间之后出现了频繁的重启。在TaskManager日志中能看到以下文本： 原因定位 首先可以看到是YarnTaskExec...
-
Apache Flink源码解析 （八）Flink的HighAvailabilityServices概述 Flink内部有一些服务是JobMaster和TaskExecutor共用的。如HighAvailabilityServices, RpcService, ActorS...
-
此简书用来发布Spark+AI的深夜学堂，每夜一更新！夜空中最亮的星：Spark！
个人介绍
Apache Flink Contributor，巴西铁杆，巴萨死忠，硬摇粉，分布式系统爱好者，github: https://github.com/Clarkkkkk