集群模式下server ip不能直接拿,比如在哪个taskmanager上执行。 如果实在想实现的话可以自己实现个SourceFunction.
在 2020/3/19 下午8:23,“512348363”<512348...@qq.com> 写入: 例如这个对应的 DataStream<String> lines = env.socketTextStream("localhost", 9999); 对应的是拉取数据, 是否存在一种模式向 flink 推送数据的呀? 拿到数据然后执行计算?