spark 讀取mysql 自增id，用getAsLong()方法解析報錯 原因：mysql中id字段的類型為 unsigned bigint ，而不是 bigint 1. ...
發(fā)簡信
IP屬地：山西
-
java.math.BigDecimal cannot be cast to java.lang.Long
-
shell 環(huán)境變量的作用域概述：shell變量的作用域，就是shell變量的有效范圍，在不同的作用域中，同名的變量不會相互干涉，就比如：A班級中有個叫小明的同學(xué)，B班級中也有一個叫小明的同學(xué)，由于他們...
-
Spark+ignite實現(xiàn)海量數(shù)據(jù)高性能OLAP海量數(shù)據(jù)多維分析我這里指的是通過數(shù)據(jù)庫，然后通過某種專業(yè)olap工具（例如cognos等）進行靈活查詢的行為，這種查詢具有以下特定： 1、行為不可控，在模型范圍內(nèi)隨意...
-
Flink利用State進行統(tǒng)計
一. 托管State 1.1 主程序 構(gòu)建 StreamExecutionEnvironment； 啟動 Checkpoint，并設(shè)置間隔時間； 設(shè)置 StateBacken...
-
Flink WaterMark 詳解背景 實時計算中，數(shù)據(jù)時間比較敏感。有eventTime和processTime區(qū)分，一般來說eventTime是從原始的消息中提取過來的，processTime是Flink...
-
JDK1.8的ConcurrentHashMap有哪些改進文章轉(zhuǎn)載自: https://www.cnblogs.com/yangfeiORfeiyang/p/9694383.html 大家應(yīng)該都知道ConcurrentHashMap...
-
spark streaming程序中kafka rebalance原因排查
1.Rebalance 的觸發(fā)條件有3個。 組成員個數(shù)發(fā)生變化。例如有新的 consumer 實例加入該消費組或者離開組 訂閱的 Topic 個數(shù)發(fā)生變化 訂閱的 Topi...
-
Mac 系統(tǒng)，如何卸載自啟動的 creative cloud在mac系統(tǒng)中，如果你安裝了photoshop的話，就會被買一贈一，免費贈送一個creative cloud。并且十分不爽的是：這個creative cloud是個自啟動的東...
-
獲取任意Linux時間戳1. Unix時間戳在線網(wǎng)址 2. 實例：根據(jù)當前時間和時區(qū)，獲取當前時區(qū)凌晨（00:00:00）的時間戳 2.1 java8 api的方式 2.2 shell方式
