logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

2022版本的idea没有定位图标

2022版本的idea没有定位图标

#intellij-idea#ide
DolphinScheduler 启动flink任务报错 Could not start rest endpoint on any port in port range 8081

rest.port: 8082,后面继续在海豚启动任务,发现还是报端口连不上的错,报错端口从8081变成了8082;一开始我以为是端口问题,然后在flink的配置文件。然后我继续百度,终于发现了。

#flink#大数据
DolphinScheduler启动flink任务, 用Flink消费Kafka数据(linux)

1、修改kafka配置:找到kafka安装包下的config文件夹,修改config下的server.properties文件,修改listeners是为了外面的主机能够访问到虚拟机的kafka,还有把advertised.listeners改成虚拟机地址,写样例的时候能连上虚拟机的kafka地址,不然默认连localhost。flink的启动日志,我这里写了消费两条消息后取消flink任务,因为

#flink#kafka#大数据
DolphinScheduler启动flink任务, 用Flink消费Kafka数据(linux)

1、修改kafka配置:找到kafka安装包下的config文件夹,修改config下的server.properties文件,修改listeners是为了外面的主机能够访问到虚拟机的kafka,还有把advertised.listeners改成虚拟机地址,写样例的时候能连上虚拟机的kafka地址,不然默认连localhost。flink的启动日志,我这里写了消费两条消息后取消flink任务,因为

#flink#kafka#大数据
启动项目报错unsupported JNI version 0xFFFFFFFF required by D:\apache-tomcat-8.5.41\bin\tcnative-1.dll

启动项目报错unsupported JNI version 0xFFFFFFFF required by D:\apache-tomcat-8.5.41\bin\tcnative-1.dll,通常表示 Tomcat 在尝试加载。这可能与 Java Native Interface (JNI) 版本不匹配或者 DLL 文件与当前使用的 Java 版本不兼容有关。我原本用的jdk版本是1.8.102,

#apache#tomcat#java
DBeaver连接Oracle数据库报错

错误:Can’t create driver instanceError creating driver ‘Oracle’ instance.Most likely required jar files are missing.You should configure jars in driver settings.webReason: can’t load driver class ‘oracl

#oracle#数据库
DolphinScheduler启动flink任务, 用Flink消费Kafka数据(linux)

1、修改kafka配置:找到kafka安装包下的config文件夹,修改config下的server.properties文件,修改listeners是为了外面的主机能够访问到虚拟机的kafka,还有把advertised.listeners改成虚拟机地址,写样例的时候能连上虚拟机的kafka地址,不然默认连localhost。flink的启动日志,我这里写了消费两条消息后取消flink任务,因为

#flink#kafka#大数据
DolphinScheduler启动flink任务, 用Flink消费Kafka数据(linux)

1、修改kafka配置:找到kafka安装包下的config文件夹,修改config下的server.properties文件,修改listeners是为了外面的主机能够访问到虚拟机的kafka,还有把advertised.listeners改成虚拟机地址,写样例的时候能连上虚拟机的kafka地址,不然默认连localhost。flink的启动日志,我这里写了消费两条消息后取消flink任务,因为

#flink#kafka#大数据
idea右键项目没有出现git选项、idea工具栏没有Git快捷图标

idea右键项目没有出现git选项、工具栏没有Git快捷图标

文章图片
#intellij-idea#git#java
DolphinScheduler启动flink任务, 用Flink消费Kafka数据(linux)

1、修改kafka配置:找到kafka安装包下的config文件夹,修改config下的server.properties文件,修改listeners是为了外面的主机能够访问到虚拟机的kafka,还有把advertised.listeners改成虚拟机地址,写样例的时候能连上虚拟机的kafka地址,不然默认连localhost。flink的启动日志,我这里写了消费两条消息后取消flink任务,因为

#flink#kafka#大数据
    共 12 条
  • 1
  • 2
  • 请选择