阿里云官網(wǎng)內(nèi)容平臺(tái)！匯聚阿里云優(yōu)質(zhì)內(nèi)容（入門、文檔伐谈、案例、最佳實(shí)踐、直播等）挠日！如需轉(zhuǎn)載或內(nèi)容類合作，郵件yqgroup@service.aliyun.com 秒級(jí)回復(fù)翰舌！<br>
發(fā)簡(jiǎn)信
IP屬地：吉林
-
-
Flink on yarn部署模式Flink on yarn部署模式 背景 Flink是一個(gè)高性能懂算，高吞吐，低延遲的流處理框架庇麦。它不僅僅是作為一個(gè)流式處理框架计技，更將批處理統(tǒng)一了起來（在Flink中，批處理是流...
-
SparkStreaming如何優(yōu)雅的停止服務(wù)
我們都知道SparkStreaming程序是一個(gè)長(zhǎng)服務(wù)山橄，一旦運(yùn)轉(zhuǎn)起來不會(huì)輕易停掉垮媒，那么如果我們想要停掉正在運(yùn)行的程序應(yīng)該怎么做呢？如果運(yùn)行的是spark on yarn模式直...
-
-
SparkStreaming入門教程(四)有狀態(tài)和無狀態(tài)的轉(zhuǎn)化操作
本文全部手寫原創(chuàng)，請(qǐng)勿復(fù)制粘貼饮醇、轉(zhuǎn)載請(qǐng)注明出處它抱，謝謝配合！ Dstream的轉(zhuǎn)化操作分為無狀態(tài)的(stateless)和有狀態(tài)的(stateful)無狀態(tài)轉(zhuǎn)化：每個(gè)批次處理都...
-
（十一）SparkStreaming數(shù)據(jù)零丟失--使用jdbc存儲(chǔ)offset
1.MySQL創(chuàng)建存儲(chǔ)offset的表格 2. Maven依賴包 3. 處理思路 1）StreamingContext2）從kafka中獲取數(shù)據(jù)(從外部存儲(chǔ)獲取offset-...
-
-
和一些做技術(shù)的朋友建了一個(gè)大數(shù)據(jù)蜘腌、機(jī)器學(xué)習(xí)的QQ群（有BAT的大佬）沫屡，歡迎加入、交流撮珠、學(xué)習(xí)沮脖！<br>QQ群：432600958
-
Flink 寫入數(shù)據(jù)到 KafkaFlink 寫入數(shù)據(jù)到Kafka 前言 通過Flink官網(wǎng)可以看到Flink里面就默認(rèn)支持了不少sink，比如也支持Kafka sink connector（FlinkKaf...
