自学内容网 自学内容网

Flink1.19编译并Standalone模式本地运行

1.首先下载源码

2.本地运行

新建local_conf和local_lib文件夹,并且将编译后的文件放入对应的目录

2.1 启动前参数配置

2.1.2 StandaloneSessionClusterEntrypoint启动参数修改

 2.1.3 TaskManagerRunner启动参数修改

和StandaloneSessionClusterEntrypoint一样修改

-Dlog.file=./log/flink-taskmanager-1.local.log -Dlog4j.configuration=./alocal_conf/log4j.properties -Dlog4j.configurationFile=./alocal_conf/log4j.properties -Dlogback.configurationFile=./alocal_conf/logback.xml

2.2 启动

先启动StandaloneSessionClusterEntrypoint

再启动TaskManagerRunner

遇到的问题:

1.no scalac found to compile scala sources

2.最开始采用java11编译没问题运行出错,程序包sun.misc不存在 之后修改为java8

3.由于taskmanager的文件目录生成有特殊符号,在windows中文件目录不允许有特殊符号,所以修改这里


原文地址:https://blog.csdn.net/weixin_45249411/article/details/143778505

免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!