發(fā)簡(jiǎn)信
IP屬地：內(nèi)蒙古
-
奇妙的 JDBC batch insert 到 Doris 異常的問題遇到一個(gè)很奇怪的異常，通過 JDBC batch insert 時(shí)漾峡，會(huì)報(bào) Unknown command(27) 的異常。 而且這個(gè)問題很容易復(fù)...
-
Kafka GetOffsetShellparseOffsetSpec 根據(jù) time 配置解析出獲取 offset 的方式枉侧，earliest、lastest或者指定的時(shí)間戳 然后通過...
-
cas
CAS，即Compare-And-Swap比較并交換，它是一條CPU并發(fā)原語 它的功能是判斷內(nèi)存某個(gè)位置的值是否為預(yù)期值薇宠，如果是則改為新的值，這...
-
線程池使用及優(yōu)勢(shì)
線程池使用及優(yōu)勢(shì) 線程池的主要工作是控制運(yùn)行的線程數(shù)量艰额，處理過程中將任務(wù)放入隊(duì)列澄港，然后在線程創(chuàng)建后啟動(dòng)這些任務(wù)，如果線程數(shù)超過了最大數(shù)量悴晰，超出數(shù)...
-
volatile關(guān)鍵字volatile是Java虛擬機(jī)提供的輕量級(jí)的同步機(jī)制 具有三大特性： 保證可見性 不保證原子性 禁止指令重排 要想講清楚這三大特性，首先要了解...
-
ClassNotFoundException和NoClassDefFoundError
ClassNotFoundException ClassNotFoundException一個(gè)異常逐工，該異常為已檢查異常（Checked Exce...
-
Spark-task執(zhí)行過程中的序列化
先看一個(gè)例子： 運(yùn)行后結(jié)果： Exception in thread "main" org.apache.spark.SparkExceptio...
-
Spark-通信架構(gòu)
Spark 2.x版本使用Netty通訊框架作為內(nèi)部通訊組間铡溪。Spark基于Netty新的RPC框架借鑒了Akka中的設(shè)計(jì)，基于Actor模型泪喊。...
-
Spark-DStream數(shù)據(jù)轉(zhuǎn)換
DStream的原語與RDD類似棕硫，分文轉(zhuǎn)換（Transformation）和輸出（Output）兩種，此外還有一些特殊的原語袒啼，如：updateS...