Re: 获取flinksql返回的查询结果

最近刚好做了这个功能，基本的原理如Jeff所说，提交到集群后sink到内存。
然后在本地创建socket server，sink到内存的数据直接通过socket传回到本地。


具体做法即可以参考zeppelin，也可以参考sql-client模块的ChangelogCollectStreamResult



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复