- 主题:flink服务器环境不执行main函数的?
我在main里面读取args用作各种配置
本地正常读取没问题
服务器环境发现main里面的代码没有被执行
服务器环境flink不拿我的main作为程序入口的?
我要怎么才能获取args的内容
--
FROM 223.167.199.*
我告诉了
所以服务器环境,也是从main入口走的?
那我再看看
【 在 here080 (hero080) 的大作中提到: 】
: 你得告诉启动程序的程序你的Main class吧?
--
FROM 223.167.199.*
大概搞明白了
flink有task manager
程序实际运行在 task manager上面
但是看上去flink不是把jar分发到各个task manager上面去启动执行
而是把算子和sink等对象序列化之后,把序列化的对象发到task节点上执行
因此我在main里面初始化的各种singleton对象并没有被一起带过去,导致了空指针
不知道我理解的对不对
【 在 here080 (hero080) 的大作中提到: 】
: 你得告诉启动程序的程序你的Main class吧?
--
FROM 223.167.199.*
RichSinkFunction的open(Configuration parameters)
看上去是可以获取到一些参数
不过Configuration要在哪里设定?
【 在 emirbobo (骑白马的) 的大作中提到: 】
: 差不多这个意思,要main 和sink 都能用到的话可以配置GlobalJobParameters
--
FROM 180.157.249.*