Flink HA Flink HA 的HighAvailabilityMode類中定義了是那種高可用性模式枚舉: NONE:非HA模式ZOOKEEPER:基于ZK實(shí)現(xiàn)HAFA...
發(fā)簡(jiǎn)信
IP屬地：廣東
-
Flink 生產(chǎn)實(shí)踐
-
請(qǐng)問(wèn)下博主，flink版本和scala版本是多少？
Flink 使用之 Oracle CDC
Flink 使用介紹相關(guān)文檔目錄 Flink 使用介紹相關(guān)文檔目錄[http://m.itdecent.cn/p/74f1990d047c] 準(zhǔn)備工作 在這一步需要配置...
-
-
@dozenx 額，你是？
開(kāi)啟kerberos后HBASE client配置
開(kāi)啟了kerberos之后的集群,用hbase client連接需要增加相應(yīng)的配置,如果配置不正確很容易出現(xiàn)kerberos認(rèn)證失敗的錯(cuò)誤,因?yàn)榫W(wǎng)上搜到的錯(cuò)誤原因分析五花八門...
-
MySql實(shí)現(xiàn)ROW_NUMBER()開(kāi)窗函數(shù)
本文咱們使用mysql實(shí)現(xiàn)開(kāi)窗函數(shù)row_number() over (partition by xxx,xxx order by xxx)，廢話不多說(shuō)，直接開(kāi)干 準(zhǔn)備數(shù)據(jù) ...
-
CM集群中修改spark應(yīng)用內(nèi)存
工作中可能會(huì)遇到這種問(wèn)題： 集群的spark工作內(nèi)存太小，比如只有50個(gè)G，如果想讓spark工作內(nèi)存變成100個(gè)G，則需要在CM控制臺(tái)修改以下兩個(gè)參數(shù)
-
Mysql數(shù)據(jù)導(dǎo)出到Hbase
Mysql表center_pub_merchant數(shù)據(jù)導(dǎo)出為center_pub_merchant.tsv Mysql表center_pub_device數(shù)據(jù)導(dǎo)出為cente...
-
SparkRDD轉(zhuǎn)DataFrame的兩種方式
SparkRDD轉(zhuǎn)DataFrame 映射的方式 SparkRDD轉(zhuǎn)DataFrame 構(gòu)造元數(shù)據(jù)的方式
-
Lateral View和Explode用法簡(jiǎn)介一、Explode用法 hive wiki對(duì)于expolde的解釋如下： explode() takes in an array (or a map) as an input...
-
CentOS6.5安裝Presto
一、準(zhǔn)備hdfs、hive基礎(chǔ)集群環(huán)境，兩臺(tái)虛機(jī)hd01、hd02 二、下載Presto相關(guān)安裝包： https://repo1.maven.org/maven2/com/f...
-
@guoqian123 嗯嗯，已經(jīng)知道了，謝謝博主
開(kāi)啟kerberos后HBASE client配置
開(kāi)啟了kerberos之后的集群,用hbase client連接需要增加相應(yīng)的配置,如果配置不正確很容易出現(xiàn)kerberos認(rèn)證失敗的錯(cuò)誤,因?yàn)榫W(wǎng)上搜到的錯(cuò)誤原因分析五花八門...
-
String nsName = "mynamespace"; 請(qǐng)問(wèn)下，這個(gè)是什么名字？
開(kāi)啟kerberos后HBASE client配置
開(kāi)啟了kerberos之后的集群,用hbase client連接需要增加相應(yīng)的配置,如果配置不正確很容易出現(xiàn)kerberos認(rèn)證失敗的錯(cuò)誤,因?yàn)榫W(wǎng)上搜到的錯(cuò)誤原因分析五花八門...
-
用MackDown語(yǔ)法寫hexo博客「簡(jiǎn)書」作為一款「寫作軟件」在誕生之初就支持了 Markdown，Markdown 是一種「電子郵件」風(fēng)格的「標(biāo)記語(yǔ)言」，我們強(qiáng)烈推薦所有寫作者學(xué)習(xí)和掌握該語(yǔ)言。為什么？可以...
-
前端小菜鳥(niǎo)~
