spark 读取mysql 自增id，用getAsLong()方法解析报错 原因：mysql中id字段的类型为 unsigned bigint ，而不是 bigint 1. ...
发简信
IP属地：山西
-
java.math.BigDecimal cannot be cast to java.lang.Long
-
shell 环境变量的作用域概述：shell变量的作用域，就是shell变量的有效范围，在不同的作用域中，同名的变量不会相互干涉，就比如：A班级中有个叫小明的同学，B班级中也有一个叫小明的同学，由于他们...
-
Spark+ignite实现海量数据高性能OLAP海量数据多维分析我这里指的是通过数据库，然后通过某种专业olap工具（例如cognos等）进行灵活查询的行为，这种查询具有以下特定： 1、行为不可控，在模型范围内随意...
-
Flink利用State进行统计
一. 托管State 1.1 主程序 构建 StreamExecutionEnvironment； 启动 Checkpoint，并设置间隔时间； 设置 StateBacken...
-
Flink WaterMark 详解背景 实时计算中，数据时间比较敏感。有eventTime和processTime区分，一般来说eventTime是从原始的消息中提取过来的，processTime是Flink...
-
JDK1.8的ConcurrentHashMap有哪些改进文章转载自: https://www.cnblogs.com/yangfeiORfeiyang/p/9694383.html 大家应该都知道ConcurrentHashMap...
-
spark streaming程序中kafka rebalance原因排查
1.Rebalance 的触发条件有3个。 组成员个数发生变化。例如有新的 consumer 实例加入该消费组或者离开组 订阅的 Topic 个数发生变化 订阅的 Topi...
-
Mac 系统，如何卸载自启动的 creative cloud在mac系统中，如果你安装了photoshop的话，就会被买一赠一，免费赠送一个creative cloud。并且十分不爽的是：这个creative cloud是个自启动的东...
-
获取任意Linux时间戳1. Unix时间戳在线网址 2. 实例：根据当前时间和时区，获取当前时区凌晨（00:00:00）的时间戳 2.1 java8 api的方式 2.2 shell方式
