Avatar notebook default
Flink
10篇文章 · 12084字 · 1人关注
  • Resize,w 360,h 240
    Flink Checkpoint变迁与实践

    一、历史变迁 在Flink 1.0.0时期 提供了RocksDB的支持，这个版本之前所有的状态都只能存在进程的内存里面，这个内存总有存不下的一天...

    0.1 2553 0 1
  • Flink异常指南

    1、Checkpoint失败：Checkpoint expired before completing 原因是因为checkpointConf....

    0.7 11665 0 8
  • 初识Flink WaterMarker

    前言 对于流计算来说，最核心的概念就是无穷数据集，而用来处理无穷数据集的计算就可以称为流计算。面对无穷数据集，有多种多样的处理方式，但是大致上可...

    0.1 2419 1 1
  • Resize,w 360,h 240
    Jobs and Scheduling

    Scheduling 1、Flink的Execution resources是通过Task Slots定义的。每个TaskManager 都有一...

    499 0 0
  • MemorySegment

    概述 就像我们所知道的，Flink采用了自己管理内存的方式，或者说积极的内存管理，而MemorySegment就是Flink实现自己内存管理的核...

    1908 0 0
  • Resize,w 360,h 240
    Data exchange between tasks

    基本原则 https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+bet...

    678 0 0
  • Resize,w 360,h 240
    Rescaling Stateful Applications in Production

    一、概述 数据局部性是Flink中的一个关键原则，并且强烈影响状态的存储和访问方式。Flink中的状态都是Local State。Why loc...

    1004 0 0
  • Resize,w 360,h 240
    Actor system(Akka) in Flink

    一、概述 Flink's distributed execution consists of two important processes, ...

    0.1 2848 0 1
  • Resize,w 360,h 240
    Physical Partitioning in Flink Streaming

    一、Physical partitioning 在一个transformation之后，Flink也提供了底层API以允许用户在必要时精确控制流...

    1978 1 0

文集作者