1 Star 0 Fork 17

wz/Flink_Code

forked from Appleyuchi/Flink_Code 
加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
check_point_knowledge.mm 5.62 KB
一键复制 编辑 原始数据 按行查看 历史
fastsource 提交于 2020-10-07 15:16 . datastream api整理暂时告一段落
<map version="1.0.1">
<!-- To view this file, download free mind mapping software FreeMind from http://freemind.sourceforge.net -->
<node CREATED="1600130463692" ID="ID_853449302" MODIFIED="1600140241435" TEXT="&#x6570;&#x636e;&#x4ed3;&#x5e93;">
<node CREATED="1600140207523" ID="ID_1336102038" MODIFIED="1600140221207" POSITION="right" TEXT="&#x79bb;&#x7ebf;&#x4ed3;&#x5e93;(&#x6279;&#x5904;&#x7406;)"/>
<node CREATED="1600140208845" ID="ID_1121331582" MODIFIED="1600140238017" POSITION="right" TEXT="&#x5b9e;&#x65f6;&#x4ed3;&#x5e93;(&#x6d41;&#x5904;&#x7406;)">
<node CREATED="1600440682437" ID="ID_1190905283" MODIFIED="1600440977571" TEXT="check point">
<node CREATED="1600440934055" ID="ID_1597611352" MODIFIED="1600441054492" TEXT="checkPointMode">
<node CREATED="1600440998533" ID="ID_1342498825" MODIFIED="1600441605352" TEXT="Exactly-once(&#x9ed8;&#x8ba4;)"/>
<node CREATED="1600441029904" ID="ID_157659898" MODIFIED="1600441042477" TEXT="At-least-once"/>
</node>
<node CREATED="1600440936318" ID="ID_1512235939" MODIFIED="1600441024841" TEXT="State Backend">
<node CREATED="1600441058671" ID="ID_1333411869" MODIFIED="1600832456919" TEXT="MemoryStateBackend">
<node CREATED="1600832440161" ID="ID_1054133981" MODIFIED="1600832450167" TEXT="OnYarn&#x6700;&#x4f73;&#x6a21;&#x5f0f;"/>
<node CREATED="1600832476362" ID="ID_1602343364" MODIFIED="1600832497716" TEXT="CheckPoint&#x6570;&#x636e;&#x76f4;&#x63a5;&#x8fd4;&#x56de;&#x7ed9;Master&#x8282;&#x70b9;"/>
<node CREATED="1600842067330" ID="ID_9686617" LINK="https://www.jianshu.com/p/03cd436dd4a3" MODIFIED="1600842088856" TEXT="&#x4e0d;&#x5efa;&#x8bae;&#x5728;&#x7ebf;&#x4e0a;&#x4f7f;&#x7528;"/>
<node CREATED="1600842807093" ID="ID_27979538" LINK="https://www.jianshu.com/p/64e8588740e0" MODIFIED="1600842843856" TEXT="&#x4e0d;&#x53ef;&#x7528;&#x5728;&#x751f;&#x4ea7;&#x73af;&#x5883;"/>
</node>
<node CREATED="1600441068383" ID="ID_62990020" MODIFIED="1600832464264" TEXT="FsStateBackend">
<node CREATED="1600832467242" ID="ID_1501456792" MODIFIED="1600832474457" TEXT="Standalone&#x6700;&#x4f73;&#x6a21;&#x5f0f;"/>
<node CREATED="1600832477507" ID="ID_1495262691" MODIFIED="1600842439562" TEXT="&#x5927;&#x4e8e;&#x4e00;&#x5b9a;&#x9608;&#x503c;&#x65f6;&#x4f1a;&#x5c06;&#x6570;&#x636e;&#x5199;&#x5165;&#x6587;&#x4ef6;&#x4e2d;,&#xa;&#x6587;&#x4ef6;&#x8def;&#x5f84;&#x4f20;&#x9012;&#x7ed9;Master&#x8282;&#x70b9;"/>
<node CREATED="1600832720365" ID="ID_219994961" MODIFIED="1600832728097" TEXT="&#x6027;&#x80fd;&#x597d;&#xff0c;&#x6709;OOM&#x98ce;&#x9669;"/>
<node CREATED="1600833895720" ID="ID_560637245" MODIFIED="1600833906918" TEXT="&#x8bfb;&#x5199;&#x7684;&#x65f6;&#x5019;&#x4e0d;&#x8d70;&#x5e8f;&#x5217;&#x5316;&#x548c;&#x53cd;&#x5e8f;&#x5217;&#x5316;"/>
<node CREATED="1600833997825" ID="ID_304612220" MODIFIED="1600834004911" TEXT="&#x4e0d;&#x652f;&#x6301;&#x589e;&#x91cf;CheckPoint"/>
</node>
<node CREATED="1600441069200" ID="ID_1430504305" MODIFIED="1600441080006" TEXT="RocksDBStateBackend">
<node CREATED="1600832590660" ID="ID_1314668803" MODIFIED="1600832603986" TEXT="&#x5c06;Rocksdb&#x6587;&#x4ef6;&#x4e0a;&#x4f20;&#x5230;HDFS,&#x6587;&#x4ef6;&#x8def;&#x5f84;&#x4f20;&#x9012;&#x7ed9;Master"/>
<node CREATED="1600834065337" ID="ID_953999657" MODIFIED="1600834069302" TEXT="&#x65e0;&#x9700;&#x62c5;&#x5fc3;OOM&#x98ce;&#x9669;"/>
<node CREATED="1600833910961" ID="ID_1383539429" MODIFIED="1600833917948" TEXT="&#x8bfb;&#x5199;&#x65f6;&#x8d70;&#x5e8f;&#x5217;&#x5316;&#x548c;&#x53cd;&#x5e8f;&#x5217;&#x5316;"/>
<node CREATED="1600833944423" ID="ID_1123631237" MODIFIED="1600833949684" TEXT="&#x8981;&#x8d70;JNI"/>
<node CREATED="1600834161051" ID="ID_864137013" MODIFIED="1600834166123" TEXT="&#x652f;&#x6301;&#x589e;&#x91cf;CheckPoint"/>
</node>
<node CREATED="1600842212811" ID="ID_1208731997" MODIFIED="1600842404289" TEXT="GeminiStateBackend(Blink&#x7279;&#x6709;,&#xa;Blink&#x540e;&#x671f;&#x4f1a;&#x5408;&#x5e76;&#x5165;Flink)"/>
</node>
</node>
<node CREATED="1600440910124" ID="ID_397655918" MODIFIED="1600440914505" TEXT="save point"/>
<node CREATED="1600441132801" ID="ID_925393918" MODIFIED="1602039150439" TEXT="state&#x6982;&#x5ff5;">
<node CREATED="1600441535448" ID="ID_732817294" MODIFIED="1600831913834" TEXT="Keyed State">
<node CREATED="1600831899781" ID="ID_1659766077" MODIFIED="1600831904507" TEXT="current key"/>
<node CREATED="1600832061647" ID="ID_438830085" MODIFIED="1600832076958" TEXT="&#x5806;&#x5185;&#x5b58;,Rocksdb"/>
<node CREATED="1600832179095" ID="ID_1313262661" MODIFIED="1600832198437" TEXT="&#x7531;backend&#x5b9e;&#x73b0;"/>
<node CREATED="1600832205808" ID="ID_76606190" MODIFIED="1600832290739" TEXT="&#x6570;&#x636e;&#x89c4;&#x6a21;&#x5927;"/>
</node>
<node CREATED="1600441536944" ID="ID_1028579959" MODIFIED="1600831877302" TEXT="Operator State">
<node CREATED="1600831860194" ID="ID_419266772" MODIFIED="1600831894332" TEXT="&#x65e0;current key"/>
<node CREATED="1600831868189" ID="ID_745154955" MODIFIED="1600832081258" TEXT="&#x5806;&#x5185;&#x5b58;"/>
<node CREATED="1600832162215" ID="ID_1825896200" MODIFIED="1600832174341" TEXT="&#x624b;&#x52a8;&#x5b9e;&#x73b0;snapshot&#x548c;restore"/>
<node CREATED="1600832212752" ID="ID_1911697556" MODIFIED="1600832293487" TEXT="&#x6570;&#x636e;&#x89c4;&#x6a21;&#x5c0f;"/>
</node>
</node>
<node CREATED="1602039150983" ID="ID_1279779952" MODIFIED="1602039155713" TEXT="state&#x5185;&#x5bb9;">
<node CREATED="1602039164586" ID="ID_1996821933" MODIFIED="1602039174096" TEXT="Keyed State">
<node CREATED="1602039199392" ID="ID_607573654" MODIFIED="1602039199392" TEXT=""/>
</node>
<node CREATED="1602039168029" ID="ID_1845676179" MODIFIED="1602039189175" TEXT="Operator State">
<node CREATED="1602039203165" ID="ID_1887271290" MODIFIED="1602039203165" TEXT=""/>
</node>
</node>
</node>
</node>
</map>
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/sanmei_test/Flink_Code.git
git@gitee.com:sanmei_test/Flink_Code.git
sanmei_test
Flink_Code
Flink_Code
master

搜索帮助