标签： 常见错误

Kafka启动报错： Kafka注册到Zookeeper，Zookeeper也报错： Kafka的错误已经比较… 继续阅读 Kafka启动报错：ERROR Error while loading log dir tmp kafka-logs

idea创建项目maven报错： 问题原因：主要是因为idea和maven版本导致的，要么是idea版本过高，… 继续阅读 idea创建项目maven报错java.lang.NoSuchMethodError

Flink运行时报错： 根本问题是版本问题，早期版本StreamExecutionEnvironment中默认… 继续阅读 Flink运行时报错：Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy

git执行add命令是报错： 最简单的处理就是重启电脑，因为你操作了两个git的工作空间，其中前一个git的线… 继续阅读 Git报错：fatal Unable to create xxx目录.git index.lock File exists

看异常其实问题已经比较明显了： 代码： keyBy用法keyBy(0)或者keyBy(item->ite… 继续阅读 Flink运行时报错：Specifying keys via field positions is only valid for tuple data types

报错原因是因为连不上Kafka连不上的原因是因为Java连kafka，kafka需要添加一个配置：advert… 继续阅读 Java连接kafka超时报错

原因是Cannot reference field by position on PojoType，虽然编译器… 继续阅读 Flink运行时报错：Cannot reference field by position on PojoType

代码： 原因：Lambda无法通过表达式推断出正确的类型 改造代码：1、第一种方法就是使用匿名类 输出结果： … 继续阅读 Flink运行时报错：could not be determined automatically, due to type erasure

本地IDE运行Flink代码，报错如下： 问题解决：问题出在pom文件中，其中引入的Flink包的scope为… 继续阅读 Flink运行报错：java.lang.NoClassDefFoundError: org/apache/flink/streaming/api/functions/source/SourceFunction