新建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中文件目录不允许有特殊符号,所以修改这里