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)!