大概搞明白了
flink有task manager
程序实际运行在 task manager上面
但是看上去flink不是把jar分发到各个task manager上面去启动执行
而是把算子和sink等对象序列化之后，把序列化的对象发到task节点上执行
因此我在main里面初始化的各种singleton对象并没有被一起带过去，导致了空指针
不知道我理解的对不对
【 在 here080 (hero080) 的大作中提到: 】
: 你得告诉启动程序的程序你的Main class吧？
--
FROM 223.167.199.*