前言 如果要列舉Flink SQL新手有可能犯的錯(cuò)誤岔绸，筆者認(rèn)為其中之一就是忘記設(shè)置空閑狀態(tài)保留時(shí)間導(dǎo)致?tīng)顟B(tài)爆炸。2021年的第一篇技術(shù)文弟疆，時(shí)間很緊張，聊聊這個(gè)簡(jiǎn)單的話題吧盗冷。 ...
發(fā)簡(jiǎn)信
IP屬地：廣東
-
Flink SQL空閑狀態(tài)保留時(shí)間（idle state retention time）實(shí)現(xiàn)原理 -
數(shù)據(jù)分析實(shí)踐 | flink | window窗口篇要弄懂flink全部的工作機(jī)制其實(shí)是一件比較麻煩的事情怠苔，零碎的概念太多，對(duì)于第一次接觸flink的我也算是個(gè)挑戰(zhàn)仪糖。 整體感受就是--看官方文檔的過(guò)程就像在做高中的閱讀理解：）...
-
Flink Window觸發(fā)機(jī)制
1. Flink的Window類(lèi)型 Flink基本分有3種window類(lèi)型：CountWindow嘀略，TimeWindow和SessionWindow。其中乓诽，CountWind...
-
Elasticsearch的底層模塊深入解析之shard allocation
1、shard allocation的介紹 兩種node：master node咒程，data node master node的一個(gè)很重要的功能鸠天，比如說(shuō)，你現(xiàn)在創(chuàng)建了一個(gè)索引帐姻，...
-
flink的內(nèi)存管理在大數(shù)據(jù)面前稠集，JVM的內(nèi)存結(jié)構(gòu)和GC機(jī)制往往會(huì)成為掣肘 1. 對(duì)象開(kāi)銷(xiāo)：在HotSpot中，每個(gè)對(duì)象占用的內(nèi)存空間必須是8的倍數(shù)饥瓷。這就導(dǎo)致每個(gè)對(duì)象占據(jù)的內(nèi)存空間包含三部分：頭...
-
spark-streaming-kafka之createDirectStream模式
完整工程用例 最近一直在用directstream方式消費(fèi)kafka中的數(shù)據(jù)剥纷，特此總結(jié)，整個(gè)代碼工程分為三個(gè)部分一. 完整工程代碼如下(某些地方特意做了說(shuō)明, 這個(gè)代碼的部...
-
2015 Bossie評(píng)選：最佳開(kāi)源大數(shù)據(jù)工具//2015 Bossie評(píng)選：最佳開(kāi)源大數(shù)據(jù)工具-CSDN.NEThttp://www.csdn.net/article/2015-10-20/2825959ddply 摘...
-
Apache Ranger安裝配置以及和LDAP集成
導(dǎo)語(yǔ) Ranger是Hadoop平臺(tái)的集中式安全管理框架呢铆，能夠?yàn)閔adoop平臺(tái)組件提供細(xì)粒度的訪問(wèn)控制晦鞋。通過(guò)Ranger, Hadoop管理員能夠輕松地管理各種安全策略，包...
-
心有猛虎棺克，細(xì)嗅薔薇--10本電子好書(shū)推薦命運(yùn)對(duì)于我們并無(wú)所謂好壞悠垛，它只供給我們好壞的原料和種子。這些原料和種子會(huì)隨時(shí)根據(jù)我們每個(gè)個(gè)體的精神特點(diǎn)發(fā)生變化娜谊，因?yàn)槲覀兠總€(gè)人才是自己幸與不幸的唯一主宰确买。鹽放入一杯水中，會(huì)咸...
