代码： 原因重点代码在这里：return instance.compare(o1,o2); 使用compare… 继续阅读 Java compare方法比较时，报错：xxx cannot be cast to java.lang.String
使用Java8的Comparator对单个和多个属性进行排序
使用Java8的Comparator进行排序，代码会显得非常简洁，不用像传统方式自定义一个类或定义一个匿名内部… 继续阅读 使用Java8的Comparator对单个和多个属性进行排序
使用Java8的Comparator对汉字进行排序
Comparator类从Java 1.2版本就已经有了，在Java8开始，加入了适用于Lambda的一些方法，… 继续阅读 使用Java8的Comparator对汉字进行排序
SpringBoot使用自定义线程池并发编程
在SpringBoot或Spring中使用并发编程变得很简单了，如果开发者不定义线程池，SpringBoot或… 继续阅读 SpringBoot使用自定义线程池并发编程
SpringBoot使用默认线程池并发编程
在SpringBoot或Spring中使用并发编程变得很简单了，如果开发者不定义线程池，SpringBoot或… 继续阅读 SpringBoot使用默认线程池并发编程
List、ArrayList执行subList报错：IndexOutOfBoundsException
List、ArrayList执行subList报错： 问题很明显是下标越界，错误代码： API使用的问题在于s… 继续阅读 List、ArrayList执行subList报错：IndexOutOfBoundsException
Linux安装新版本内核
1、安装gcc和kernel-devel编译工具链[itzhimei@localhost ~]#yum ins… 继续阅读 Linux安装新版本内核
idea多线程断点方法
1、在断点的小圆圈圈上右键 2、在弹出的窗口中选择“Thread模式” 选择“Thread”后，重新debug… 继续阅读 idea多线程断点方法
idea mybatis跳转插件
idea默认不支持从DAO层，通过快捷键跳转到对应的mybatis的xml中的功能，我们可以通过安装插件来支持… 继续阅读 idea mybatis跳转插件
Flink运行报错： No new data sinks have been defined since the last execution
Flink DataSet执行报错如下： 代码： 根据提示分析原因：在最后一行代码“env.execute()… 继续阅读 Flink运行报错： No new data sinks have been defined since the last execution
Bigdecimal devide报错：Non-terminating decimal expansion; no exact representable decimal result
Bigdecimal Divide除法计算报错： 代码： 原因：因为没有指定精度，一般加减乘可以不指定精度，除… 继续阅读 Bigdecimal devide报错：Non-terminating decimal expansion; no exact representable decimal result
Flink从入门到实战八[State]-12-Flink Key State 与 Operator State 区别
前面的章节已经讲解了Flink状态的分类和代码示例，我们来对比一下Key State 与 Operator S… 继续阅读 Flink从入门到实战八[State]-12-Flink Key State 与 Operator State 区别
Flink从入门到实战八[State]-11-Flink Broadcast State 广播状态使用示例
基于前一节我们已经对Broadcast State和其API有了一定了解，本节我们一起来编写代码，实现一个de… 继续阅读 Flink从入门到实战八[State]-11-Flink Broadcast State 广播状态使用示例
Flink从入门到实战八[State]-10-Flink Broadcast State 广播状态
Broadcast State （广播状态）：广播状态是一种特殊的算子状态。引入它的目的在于支持一个流中的元素… 继续阅读 Flink从入门到实战八[State]-10-Flink Broadcast State 广播状态
Flink从入门到实战八[State]-9-Flink Operator State的ListCheckpointed使用方法
通过实现 ListCheckpointed 接口来使用 operator state。ListCheckpoi… 继续阅读 Flink从入门到实战八[State]-9-Flink Operator State的ListCheckpointed使用方法
Flink从入门到实战八[State]-8-Flink Operator State的CheckpointedFunction使用方法
通过实现 CheckpointedFunction 接口来使用 operator state。Checkpoi… 继续阅读 Flink从入门到实战八[State]-8-Flink Operator State的CheckpointedFunction使用方法
Flink从入门到实战八[State]-7-Flink Operator State 算子状态
Operator State（算子状态）：在同一个算子上的状态，对当前算子的所有数据是共享的。需要注意的是St… 继续阅读 Flink从入门到实战八[State]-7-Flink Operator State 算子状态
Flink从入门到实战八[State]-6-Flink State 状态过期与清理
Flink里任何类型的keyed state都可以有 有效期 (TTL)。如果配置了 TTL 且状态值已过期，… 继续阅读 Flink从入门到实战八[State]-6-Flink State 状态过期与清理
Flink从入门到实战八[State]-5-Flink Keyed State MapState API使用方法
我们来看一下使用MapStateDescriptor和MapState，基于状态如何累计计算一个用户的交易数据… 继续阅读 Flink从入门到实战八[State]-5-Flink Keyed State MapState API使用方法
Flink从入门到实战八[State]-4-Flink Keyed State ValueState新版API使用方法
我们来看一下使用ValueStateDescriptor和ValueState，基于状态如何累计计算一个用户的… 继续阅读 Flink从入门到实战八[State]-4-Flink Keyed State ValueState新版API使用方法