發(fā)簡(jiǎn)信
IP屬地：甘肅
-
奇妙的 JDBC batch insert 到 Doris 異常的問(wèn)題遇到一個(gè)很奇怪的異常，通過(guò) JDBC batch insert 時(shí)，會(huì)報(bào) Unknown command(27) 的異常。 而且這個(gè)問(wèn)題很容易復(fù)...
-
Kafka GetOffsetShellparseOffsetSpec 根據(jù) time 配置解析出獲取 offset 的方式，earliest、lastest或者指定的時(shí)間戳 然后通過(guò)...
-
cas
CAS，即Compare-And-Swap比較并交換，它是一條CPU并發(fā)原語(yǔ) 它的功能是判斷內(nèi)存某個(gè)位置的值是否為預(yù)期值，如果是則改為新的值，這...
-
線程池使用及優(yōu)勢(shì)
線程池使用及優(yōu)勢(shì) 線程池的主要工作是控制運(yùn)行的線程數(shù)量，處理過(guò)程中將任務(wù)放入隊(duì)列，然后在線程創(chuàng)建后啟動(dòng)這些任務(wù)，如果線程數(shù)超過(guò)了最大數(shù)量，超出數(shù)...
-
volatile關(guān)鍵字volatile是Java虛擬機(jī)提供的輕量級(jí)的同步機(jī)制 具有三大特性： 保證可見(jiàn)性 不保證原子性 禁止指令重排 要想講清楚這三大特性，首先要了解...
-
ClassNotFoundException和NoClassDefFoundError
ClassNotFoundException ClassNotFoundException一個(gè)異常，該異常為已檢查異常（Checked Exce...
-
Spark-task執(zhí)行過(guò)程中的序列化
先看一個(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的原語(yǔ)與RDD類似，分文轉(zhuǎn)換（Transformation）和輸出（Output）兩種，此外還有一些特殊的原語(yǔ)，如：updateS...