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

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

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



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

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

2021-01-18 文章 Jeff Zhang
Sink 到内存里,然后你自己处理(print出来还是发送到web前端)
可以参考zeppelin源码 https://github.com/apache/zeppelin/tree/master/flink


黑色  于2021年1月18日周一 下午8:42写道:

> 请教个问题,我想实现类似sql-cli里功能一样,或者zepplin里的我在页面上编写select * from ,
>
>
> 在页面下面得到返回的结果显示,类似zepplin在开发区写sql,下面的输出区显示返回的结果,这个功能如何实现呢
> 各位大哥们帮忙看一看?
>
>
> 现在在flinksql上想看结果,还的定义一个with='print',跑到ui页面上去看,太麻烦了



-- 
Best Regards

Jeff Zhang