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 文末丶 <80...@qq.com.INVALID> on 2022/02/10 03:24:40 UTC

回复：Flink sql 客户端实现

https://github.com/DataLinkDC/dlink
应该满足你需求


------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <jianwen.huang.goo@gmail.com&gt;;
发送时间:&nbsp;2022年2月10日(星期四) 中午11:19
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;Flink sql 客户端实现



我想实现一个Flink sql客户端，以支持解析一段Flink sql后提交到对应的集群(K8s yarn等)。Flink
sql不需要二次开发支持更多语法特性，能兼容Flink社区版本的语法即可。
部署方式可以支持Native k8s . standalone on K8s .yarn application .perjob
等等。我查看了目前官方的flink sql client.只支持session模式。
请问有没有相关的资料或者开源项目可以进行参考。谢谢。

回复： Flink sql 客户端实现

Posted by 文末丶 <80...@qq.com.INVALID>.
或许你可以从这个项目的源码获取一些灵感和思路。




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <jianwen.huang.goo@gmail.com&gt;;
发送时间:&nbsp;2022年2月10日(星期四) 中午11:27
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;Re: Flink sql 客户端实现



感谢。是个非常好的实现。在你实现的过程中有什么可以参考的项目和资料吗。我在探索学习这块的内容。

文末丶 <809097465@qq.com.invalid&gt; 于2022年2月10日周四 11:25写道：
&gt;
&gt; https://github.com/DataLinkDC/dlink
&gt; 应该满足你需求
&gt;
&gt;
&gt; ------------------&amp;nbsp;原始邮件&amp;nbsp;------------------
&gt; 发件人:&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; "user-zh"&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <jianwen.huang.goo@gmail.com&amp;gt;;
&gt; 发送时间:&amp;nbsp;2022年2月10日(星期四) 中午11:19
&gt; 收件人:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;
&gt;
&gt; 主题:&amp;nbsp;Flink sql 客户端实现
&gt;
&gt;
&gt;
&gt; 我想实现一个Flink sql客户端，以支持解析一段Flink sql后提交到对应的集群(K8s yarn等)。Flink
&gt; sql不需要二次开发支持更多语法特性，能兼容Flink社区版本的语法即可。
&gt; 部署方式可以支持Native k8s . standalone on K8s .yarn application .perjob
&gt; 等等。我查看了目前官方的flink sql client.只支持session模式。
&gt; 请问有没有相关的资料或者开源项目可以进行参考。谢谢。

Re: Flink sql 客户端实现

Posted by JianWen Huang <ji...@gmail.com>.
感谢。是个非常好的实现。在你实现的过程中有什么可以参考的项目和资料吗。我在探索学习这块的内容。

文末丶 <80...@qq.com.invalid> 于2022年2月10日周四 11:25写道：
>
> https://github.com/DataLinkDC/dlink
> 应该满足你需求
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:                                                                                                                        "user-zh"                                                                                    <jianwen.huang.goo@gmail.com&gt;;
> 发送时间:&nbsp;2022年2月10日(星期四) 中午11:19
> 收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;
>
> 主题:&nbsp;Flink sql 客户端实现
>
>
>
> 我想实现一个Flink sql客户端，以支持解析一段Flink sql后提交到对应的集群(K8s yarn等)。Flink
> sql不需要二次开发支持更多语法特性，能兼容Flink社区版本的语法即可。
> 部署方式可以支持Native k8s . standalone on K8s .yarn application .perjob
> 等等。我查看了目前官方的flink sql client.只支持session模式。
> 请问有没有相关的资料或者开源项目可以进行参考。谢谢。