發(fā)簡信
IP屬地：湖南
-
奇妙的 JDBC batch insert 到 Doris 異常的問題遇到一個(gè)很奇怪的異常扛伍，通過 JDBC batch insert 時(shí)题诵，會報(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)勢
線程池使用及優(yōu)勢 線程池的主要工作是控制運(yùn)行的線程數(shù)量岸浑，處理過程中將任務(wù)放入隊(duì)列搏存，然后在線程創(chuàng)建后啟動(dòng)這些任務(wù)，如果線程數(shù)超過了最大數(shù)量矢洲，超出數(shù)...
-
volatile關(guān)鍵字volatile是Java虛擬機(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...