You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by 512348363 <51...@qq.com> on 2020/03/19 10:51:29 UTC

flink存在推的模式吗？

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

Re: flink存在推的模式吗？

Posted by Djeng Lee <le...@gmail.com>.

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

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

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