发简信
IP属地：新疆
遇到一个很奇怪的异常，通过 JDBC batch insert 时，会报 Unknown command(27) 的异常。 而且这个问题很容易复...
parseOffsetSpec 根据 time 配置解析出获取 offset 的方式，earliest、lastest或者指定的时间戳 然后通过...
CAS，即Compare-And-Swap比较并交换，它是一条CPU并发原语 它的功能是判断内存某个位置的值是否为预期值，如果是则改为新的值，这...
线程池使用及优势 线程池的主要工作是控制运行的线程数量，处理过程中将任务放入队列，然后在线程创建后启动这些任务，如果线程数超过了最大数量，超出数...
volatile是Java虚拟机提供的轻量级的同步机制 具有三大特性： 保证可见性 不保证原子性 禁止指令重排 要想讲清楚这三大特性，首先要了解...
ClassNotFoundException ClassNotFoundException一个异常，该异常为已检查异常（Checked Exce...
先看一个例子： 运行后结果： Exception in thread "main" org.apache.spark.SparkExceptio...
Spark 2.x版本使用Netty通讯框架作为内部通讯组间。Spark基于Netty新的RPC框架借鉴了Akka中的设计，基于Actor模型。...
DStream的原语与RDD类似，分文转换（Transformation）和输出（Output）两种，此外还有一些特殊的原语，如：updateS...