發(fā)簡信
IP屬地：北京
改版后的簡書，變的越來越像 CSDN。 博客已遷移到 Github Pages - https://ohmysummer.github.io。 ...
CDH 時鐘偏差，將 nn02 的時鐘同步為 nn01： 顯示 socket 已被使用， 因為 ntpd 服務(wù)正在運行，先停掉再同步一次：
從 mysql 讀取數(shù)據(jù)作為廣播變量時， 雖然有 checkpoint 但是 kill 掉任務(wù)后，重啟程序會失敗。
https://stackoverflow.com/questions/41505599/task-not-serializable-in-sp...
昨天把項目代碼重新整合了一下, 然后就報錯了: 原因可能是 mysql 數(shù)據(jù)庫配置的序列化問題： 但是我已經(jīng)這么序列化了。 我在類里面添加了 M...
用 parquet 數(shù)據(jù)模擬實時數(shù)據(jù)流 再將 JSON 數(shù)據(jù)逐行發(fā)到 Kafka 的不同 topic：
假設(shè)有如下數(shù)據(jù)： 要得到這樣的結(jié)果： 使用 comb 很容易把你感興趣的字段像梳子一樣給梳下來：