集群模式下server ip不能直接拿,比如在哪个taskmanager上执行。 如果实在想实现的话可以自己实现个SourceFunction. 

在 2020/3/19 下午8:23,“512348363”<512348...@qq.com> 写入:

    例如这个对应的    
    DataStream<String&gt; lines = env.socketTextStream("localhost", 9999);
    对应的是拉取数据,
    是否存在一种模式向 flink 推送数据的呀?
    拿到数据然后执行计算?

回复