使用Java8的Comparator进行排序,代码会显得非常简洁,不用像传统方式自定义一个类或定义一个匿名内部… 继续阅读 使用Java8的Comparator对单个和多个属性进行排序
分类: Java基础
使用Java8的Comparator对汉字进行排序
Comparator类从Java 1.2版本就已经有了,在Java8开始,加入了适用于Lambda的一些方法,… 继续阅读 使用Java8的Comparator对汉字进行排序
List、ArrayList执行subList报错:IndexOutOfBoundsException
List、ArrayList执行subList报错: 问题很明显是下标越界,错误代码: API使用的问题在于s… 继续阅读 List、ArrayList执行subList报错:IndexOutOfBoundsException
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
idea运行程序报错 java 程序包org.junit不存在
idea运行程序报错:java: 程序包org.junit不存在 第一种可能,是你的pom中没有引入junit… 继续阅读 idea运行程序报错 java 程序包org.junit不存在
Flink Table & sql执行报错:Make sure a planner module is on the classpath
Flink Table & sql执行报错: 原因是因为代码和pom引入的jar不一致。我当前测试代码… 继续阅读 Flink Table & sql执行报错:Make sure a planner module is on the classpath
OutputTag创建报错 Could not determine TypeInformation for the OutputTag type
使用Flink的侧流创建Output,报错如下: 原因在于代码中的OutputTag的定义有问题,代码如下:O… 继续阅读 OutputTag创建报错 Could not determine TypeInformation for the OutputTag type
执行数据库保存提示:Caused by:java.sql.SQLException:Access denied for user
程序连接mysql时,报错:Caused by: java.sql.SQLException: Access … 继续阅读 执行数据库保存提示:Caused by:java.sql.SQLException:Access denied for user
Kafka启动报错:ERROR Error while loading log dir tmp kafka-logs
Kafka启动报错: Kafka注册到Zookeeper,Zookeeper也报错: Kafka的错误已经比较… 继续阅读 Kafka启动报错:ERROR Error while loading log dir tmp kafka-logs
idea创建项目maven报错java.lang.NoSuchMethodError
idea创建项目maven报错: 问题原因:主要是因为idea和maven版本导致的,要么是idea版本过高,… 继续阅读 idea创建项目maven报错java.lang.NoSuchMethodError
Flink运行时报错:Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
Flink运行时报错: 根本问题是版本问题,早期版本StreamExecutionEnvironment中默认… 继续阅读 Flink运行时报错:Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
Git报错:fatal Unable to create xxx目录.git index.lock File exists
git执行add命令是报错: 最简单的处理就是重启电脑,因为你操作了两个git的工作空间,其中前一个git的线… 继续阅读 Git报错:fatal Unable to create xxx目录.git index.lock File exists
Flink运行时报错:Specifying keys via field positions is only valid for tuple data types
看异常其实问题已经比较明显了: 代码: keyBy用法keyBy(0)或者keyBy(item->ite… 继续阅读 Flink运行时报错:Specifying keys via field positions is only valid for tuple data types
kafka启动报错:Connection to node -1 (localhost/127.0.0.1:9092) could not be established
Java连接kafka超时报错
报错原因是因为连不上Kafka连不上的原因是因为Java连kafka,kafka需要添加一个配置:advert… 继续阅读 Java连接kafka超时报错
Flink运行时报错:Cannot reference field by position on PojoType
原因是Cannot reference field by position on PojoType,虽然编译器… 继续阅读 Flink运行时报错:Cannot reference field by position on PojoType
Flink运行时报错:could not be determined automatically, due to type erasure
代码: 原因:Lambda无法通过表达式推断出正确的类型 改造代码:1、第一种方法就是使用匿名类 输出结果: … 继续阅读 Flink运行时报错:could not be determined automatically, due to type erasure