Flink不同于其他实时计算的框架之处是它可以提供针对不同的状态进行编程和计算。本篇文章的主要思路如下，大家可以选择性阅读。 　　1. Flink的状态分类及不同点。 　　2. Flink针对不同的状态进行编程。 　　3. 检查点机制和配置。 　　4. 状态的存储 ...

Flink具体如何保证exactly-once呢? 它使用一种被称为"检查点"（checkpoint）的特性，在出现故障时将系统重置回正确状态。下面通过简单的类比来解释检查点的作用。 假设你和两位朋友正在数项链上有多少颗珠子，如下图所示。你捏住珠子，边数边拨，每拨过一颗珠子就给总数加一。你的朋友 ...

1. 状态一致性 当在分布式系统中引入状态时，自然也引入了一致性问题。一致性实际上是"正确性级别"的另一种说法，也就是说在成功处理故障并恢复之后得到的结果，与没有发生任何故障时得到的结果相比，前者到底有多 正确？举例来说，假设要对最近一小时登录的用户计数。在系统经历故障之后，计数结果是 ...

Flink的恢复机制，基于它的一致性检查点。前面我们已经了解了从流应用中创建检查点的简单方法——先暂停应用，保存检查点，然后再恢复应用程序，这种方法很好理解，但它的理念是“停止一切”，这对于即使是中等延迟要求的应用程序而言也是不实用的。所以Flink没有这么简单粗暴 ...

复习下前面的知识点： 1、缓冲区高速缓存（Buffer Cache）位于服务器的共享内存中，并且所有进程均可访问。在读取或更新数据时，进程将页面读入缓存。当页面位于缓存中时，我们在RAM中使用它并保存数据到磁盘。 2、当遇到掉电等故障场景，所有 RAM 内容丢失时，要在故障后恢复数据，pg ...

一、标准检查点 选择需要插入检查点的语句，点击右键，选择Insert Standard Checkpoint.... 二、图像检查点（Insert Standard Checkpoint....） 在图像上点击鼠标右键选择 出现标准检查点弹窗，点击“OK ...

事务就是一段脚本语句，在进行性能测试时事务很重要，定事务时，首先在脚本中找到事务的开始和结束位置，然后分别插入一个开始事务、结束事务，这样当脚本运行的时候，loadrunner会自动在事务的起始点计时，脚本运行到事务的结束点时计时结束，系统会自动记录这段操作的运行时间等性能数据 注意事项：事务 ...

参数化：简单的来理解一下，我们录制了一个脚本，这个脚本中有登录操作，需要输入用户名和密码，假如系统不允许相同的用户名和密码同时登录，或者想更好的模拟多个用户来登录系统。 这个时候就需 ...