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會自動在事務的起始點計時，腳本運行到事務的結束點時計時結束，系統會自動記錄這段操作的運行時間等性能數據 注意事項：事務 ...

參數化：簡單的來理解一下，我們錄制了一個腳本，這個腳本中有登錄操作，需要輸入用戶名和密碼，假如系統不允許相同的用戶名和密碼同時登錄，或者想更好的模擬多個用戶來登錄系統。 這個時候就需 ...