發(fā)簡信
IP屬地：北京
-
mac如何使用Kafka-eagle監(jiān)控Kafka（本地單機案例）1. 你需要配置好Kafka和zookeeper 1.1 JDK的安裝與配置(請自行Google) 1.2 Zookeeper的安裝與配...
-
Flink如何實現(xiàn)一個某種數(shù)據(jù)缺失半小時觸發(fā)報警的監(jiān)控問題定義：半小時監(jiān)控可以定義為整間隔時間（如9:00-9:30），也可以定義為某條數(shù)據(jù)之后的半小時 提示：若采用processingtime，我...
-
Flink如何自定義一個定時數(shù)據(jù)源
不廢話，直接上代碼，賊傻，需要什么修改自己加就完事了！?。。。?！ DataStream timerStream = env.addSource(...
-
在k8s上如何使zookeeper打印DEBUG級別日志1.請注意kubectl的版本，版本不匹配可能造成一系列問題，我們采用的使client：v1.15.1，server：v1.16.0（請注意1....
-
如何在k8s上搭建zookeeper集群
1.配置k8s集群的config文件----具體文件內(nèi)容自行搜索 2.安裝kubectl 3.創(chuàng)建svc和deployment配置文件 鏈接:h...
-
scala 如何向RabbitMQ隊列寫消息（生產(chǎn)者）
1.首先，你需要一個RabbitMQ客戶端的jar包 鏈接: https://pan.baidu.com/s/1JFZ7jblpAIsQ29k2...
-
hive中對多行進(jìn)行合并—collect_set&collect_list函數(shù)
最近在做項目的時候需要對數(shù)據(jù)組埋點得到的數(shù)據(jù)進(jìn)行合并： 1.原始數(shù)據(jù)我需要拿到post_id,district_id字段，而一個post可能投放...
個人介紹
一個AI起步失敗,又轉(zhuǎn)身一頭扎進(jìn)大數(shù)據(jù)的屌絲。?！，F(xiàn)在我tm成項目經(jīng)理了。。。東一榔頭，西一棒槌。。。