gofun

Flink HA Flink HA 的HighAvailabilityMode類中定義了是那種高可用性模式枚舉: NONE:非HA模式ZOOKEEPER:基于ZK實(shí)現(xiàn)HAFA...

gofun

請(qǐng)問下博主，flink版本和scala版本是多少蝙场？

Flink 使用之 Oracle CDC

Flink 使用介紹相關(guān)文檔目錄 Flink 使用介紹相關(guān)文檔目錄[http://www.reibang.com/p/74f1990d047c] 準(zhǔn)備工作 在這一步需要配置...

AlienPaul

15142 3 9

gofun

@dozenx 額秩彤，你是？

開啟kerberos后HBASE client配置

開啟了kerberos之后的集群,用hbase client連接需要增加相應(yīng)的配置,如果配置不正確很容易出現(xiàn)kerberos認(rèn)證失敗的錯(cuò)誤,因?yàn)榫W(wǎng)上搜到的錯(cuò)誤原因分析五花八門...

guoqian123

16104 13 4

gofun

Spark 中最基本的數(shù)據(jù)抽象是 RDD蓄坏。 RDD：彈性分布式數(shù)據(jù)集 (Resilient Distributed DataSet)。 1涡戳，RDD 有三個(gè)基本特性 這三個(gè)特性...

gofun

本文咱們使用mysql實(shí)現(xiàn)開窗函數(shù)row_number() over (partition by xxx,xxx order by xxx)胳岂，廢話不多說，直接開干 準(zhǔn)備數(shù)據(jù) ...

gofun

一般格式 下面介紹創(chuàng)建定時(shí)任務(wù)的2種方法： 方法一： 方法二： 下面列舉一些例子

gofun

spark-submit腳本： 定時(shí)任務(wù)：(可以看我另一篇關(guān)于定時(shí)任務(wù)的博客)

gofun

工作中可能會(huì)遇到這種問題： 集群的spark工作內(nèi)存太小掌测，比如只有50個(gè)G，如果想讓spark工作內(nèi)存變成100個(gè)G产园，則需要在CM控制臺(tái)修改以下兩個(gè)參數(shù)

gofun

Mysql表center_pub_merchant數(shù)據(jù)導(dǎo)出為center_pub_merchant.tsv Mysql表center_pub_device數(shù)據(jù)導(dǎo)出為cente...

gofun

SparkRDD轉(zhuǎn)DataFrame 映射的方式 SparkRDD轉(zhuǎn)DataFrame 構(gòu)造元數(shù)據(jù)的方式

gofun

一、準(zhǔn)備hdfs什燕、hive基礎(chǔ)集群環(huán)境粘勒，兩臺(tái)虛機(jī)hd01、hd02 二屎即、下載Presto相關(guān)安裝包： https://repo1.maven.org/maven2/com/f...

gofun

@guoqian123 嗯嗯庙睡，已經(jīng)知道了，謝謝博主

開啟kerberos后HBASE client配置

開啟了kerberos之后的集群,用hbase client連接需要增加相應(yīng)的配置,如果配置不正確很容易出現(xiàn)kerberos認(rèn)證失敗的錯(cuò)誤,因?yàn)榫W(wǎng)上搜到的錯(cuò)誤原因分析五花八門...

guoqian123

16104 13 4

gofun

String nsName = "mynamespace"; 請(qǐng)問下技俐，這個(gè)是什么名字乘陪？

開啟kerberos后HBASE client配置

開啟了kerberos之后的集群,用hbase client連接需要增加相應(yīng)的配置,如果配置不正確很容易出現(xiàn)kerberos認(rèn)證失敗的錯(cuò)誤,因?yàn)榫W(wǎng)上搜到的錯(cuò)誤原因分析五花八門...

guoqian123

16104 13 4