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