問題描述 在機器上執(zhí)行/usr/sbin/kadmin.local時卡住名惩,通過 systemctl重啟kadmin、kdc server也都會因為超時啟動失敗孕荠。 問題處理 使...

問題描述 在機器上執(zhí)行/usr/sbin/kadmin.local時卡住名惩,通過 systemctl重啟kadmin、kdc server也都會因為超時啟動失敗孕荠。 問題處理 使...
動機 最近需要將流程的耗時接入可觀測系統娩鹉,方便后續(xù)優(yōu)化性能。為了統一技術棧稚伍,決定使用prometheus來接入弯予。特別的是,我需要使用自定義的時間戳个曙,由于PushGateway...
版本與環(huán)境信息 組件版本hbase2.3.5hadoop3.2.2HADOOP_HOME/usr/local/service/hadoopHBASE_HOME/usr/loc...
背景 一客戶反映,通過控制臺啟動hiveserver2一直卡住呼寸,但是在機器上查看進程已經啟動 排查過程 在客戶的機器上艳汽,會啟動一個agent,用來從server端獲取指令并執(zhí)...
ISSUE https://issues.apache.org/jira/browse/HIVE-18920[https://issues.apache.org/jira/b...
函數 在go中等舔,既可以在包中定義函數骚灸,也可以定義結構體的函數,對于后者慌植,函數接收者(結構體對象)是它的第一個參數甚牲。他們都會在運行時被構造成funcval對象,而閉包就是含有捕...
[toc] 1. string的底層結構 圖最清楚了蝶柿,對于一個string類型的變量丈钙,在64位系統中,占用內存大小為16個字節(jié)交汤,分別是內存起始地址8個字節(jié)雏赦,長度8個字節(jié) 2....
1. 涉及組件 FlinkKafkaConsumer是用戶使用Kafka作為Source進行編程的入口,它有一個核心組件KafkaFetcher芙扎,用來消費kafka中的數據星岗,...
版本:1.11當是EventTime類的應用時,Watermark才有意義(IngestTime也可以生成WaterMark戒洼,很少用)俏橘,它是一個時間,表示后來的數據的Even...
前置知識: 前置知識1:Actor的創(chuàng)建 Props代表的是一個不可變的配置類圈浇,創(chuàng)建Actor時寥掐,必須要用到;它由兩部分構成 創(chuàng)建的Actor類:akkaRpcActorTy...
用來對原方法進行增強磷蜀,類結構如下: 例子 InvocationHandler 實現類 target接口 target實現 生成代理 讀者可以根據堆棧圖自己debug下生成的邏...
根據其實現的接口可知召耘,它有兩個特點: Future,表示異步執(zhí)行的結果CompletionStage褐隆,表示整個異步計算的一個階段污它,它能被其它的stage觸發(fā),也能觸發(fā)其它的s...
背景 yarn默認使用的是最簡單的FIFO調度器妓灌,即一個default隊列轨蛤,所有用戶共享,分配資源也是先到先得虫埂,沒有優(yōu)先級之分祥山。有時一兩個任務就把資源全占了,其他任務吃不到資...
前言 1 Flink基礎(適合初入職場) 簡單介紹一下 Flink Flink相比傳統的Spark Streaming區(qū)別? Flink的組件棧有哪些? Flink 的運行必...
本文僅為筆者平日學習記錄之用源祈,侵刪原文:https://mp.weixin.qq.com/s/GuA9o09EEue66fEpGgoGaQ 本文是 Flink 源碼解析系列煎源,...
隨著CPU的核數的增加,異步編程模型在并發(fā)領域中的得到了越來越多的應用香缺,由于Scala是一門函數式語言手销,天然的支持異步編程模型,今天主要來看一下Java和Scala中的Fut...
Actor作為Akka中最核心的結構图张,其在Akka中的中的組織結構也至關重要锋拖,今天我們就來講講Akka中Actor系統。 Actor系統 Actor作為一種封裝狀態(tài)和行為的對...