![240](https://upload.jianshu.io/users/upload_avatars/10111486/e0ab2948-602a-46bf-b94f-e9e471ccac65.jpeg?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
Levels of Abstraction Flink提供了不同級(jí)別的抽象 來開發(fā) 批處理/流計(jì)算。 最底層的抽象只提供了有狀態(tài)數(shù)據(jù)流敛惊。底層次有狀數(shù)據(jù)流通過 Process ...
Tasks and Operator Chains 對(duì)于分布式計(jì)算,F(xiàn)link 把operator subtasks 運(yùn)行子任務(wù)串連在一起绰更,組合成Tasks瞧挤。每個(gè)線程執(zhí)行一個(gè)...
Flink 程序是可以在分布式數(shù)據(jù)集上實(shí)現(xiàn)類似常規(guī)數(shù)據(jù)加工操作的框架 (例如:filtering, mapping, updating state, joining, gro...
Apache Flink是一個(gè)可以在有限流數(shù)據(jù)流和無限流基礎(chǔ)上進(jìn)行有狀態(tài)計(jì)算的大數(shù)據(jù)處理框架。Flink從下到上提供了不同層級(jí)的API抽象儡湾,并為常見的用例提供了專用的開發(fā)庫(kù)特恬。...
從源碼編譯Flink需要在本地安裝以下基礎(chǔ)組件. 系統(tǒng)環(huán)境: MacOS - Darwin localhost 19.5.0 Darwin Kernel Version 19...
Git Tag 操作 查看Tag 創(chuàng)建Tag tag 需要單獨(dú)創(chuàng)建譬淳,并單獨(dú)推送至遠(yuǎn)程服務(wù)器档址。而且Tag 也可以給之前push的版本打標(biāo)簽,不一定非得是當(dāng)前版本瘦赫。 刪除Tag ...
在服務(wù)器上拉取gitlab中的工程辰晕,結(jié)果報(bào)以一錯(cuò)誤: 原因是pull工程時(shí)認(rèn)證失敗。解決:使用: git clone https://username:password@gi...
Git 內(nèi)容編輯 放棄已經(jīng)修改的文件确虱,且還沒有添加到本地緩存的文件 Git Stash 操作 Git Clean 操作 Git 放棄提交到本地緩存的文件 Git 分支回退到某個(gè)版本
要學(xué)習(xí)一個(gè)Spark源碼含友,想在學(xué)習(xí)過程中加一些注釋,便于日后自己回憶校辩、與同事分享窘问。所以下載了Spark源碼,并上傳到自己github宜咒。在向遠(yuǎn)程push代碼的時(shí)候惠赫,報(bào)上面錯(cuò)誤。...
開發(fā) Spark 程序混埠,需要格式化日志輸出, 由于log4j2的性能比 log4j1.x诗轻,及 logback 好钳宪,因此配置了log4j2.xml 日志輸出配置文件。寫程序程序...
業(yè)務(wù)需要扳炬,開發(fā)一個(gè)自動(dòng)添加 監(jiān)控 flume 進(jìn)程的 crontab 任務(wù)吏颖。大概思路是 如果用戶配置了 crontab 那么把所有 crontab 內(nèi)容先輸出到一個(gè)文件中,之...
業(yè)務(wù)開發(fā)中由于數(shù)據(jù)庫(kù)設(shè)計(jì)有缺陷, 導(dǎo)致一個(gè)列中存儲(chǔ)了多個(gè)值恨樟。這種情況下半醉,在業(yè)務(wù)開發(fā)過程中, 需要將列轉(zhuǎn)換為行劝术。進(jìn)行操作缩多。如:image.png Goole 得: 參考連接:M...
MySql__為用戶賦于主從同步的權(quán)限 在配置Otter的時(shí)候報(bào)錯(cuò): 經(jīng)查詢是同步賬戶沒有權(quán)限计螺。使用同步賬戶在MySql中執(zhí)行 'show master status',出現(xiàn)...
本機(jī)MySql創(chuàng)建Otter配置表出錯(cuò): MySql建表語句是: 解決方案是設(shè)置: SET SQL_MODE = 'ALLOW_INVALID_DATES';
MySql__Mac下打開BinLog. 查看是否開啟 log_bin. 在my.cnf配置文件中打開 bin_log 選項(xiàng) 【我在本機(jī)配置了雙實(shí)例瞧壮,所以log-bin-in...