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