你得告诉启动程序的程序你的Main class吧？
【 在 guestking (无) 的大作中提到: 】
: 标  题: flink服务器环境不执行main函数的？
: 发信站: 水木社区 (Wed Jan 20 09:38:29 2021), 站内
:
: 我在main里面读取args用作各种配置
: 本地正常读取没问题
: 服务器环境发现main里面的代码没有被执行
: 服务器环境flink不拿我的main作为程序入口的？
: 我要怎么才能获取args的内容
:
: --
:
: ※ 来源:·水木社区 newsmth.net·[FROM: 223.167.199.*]
--
FROM 76.126.252.*

大概搞明白了
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.*