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 陈卓宇 <25...@qq.com.INVALID> on 2022/04/24 01:58:46 UTC

对Flink Table Store咨询

您好大佬:
&nbsp;&nbsp;&nbsp;&nbsp; 我对Flink Table Store非常感兴趣,想请教您一下怎么结合flink做断点调试,因为看了一下没有找到入口类

陈卓宇


&nbsp;

回复: 对Flink Table Store咨询

Posted by 陈卓宇 <25...@qq.com.INVALID>.
您好
-- set root path to session config SET 'table-store.path' = '/tmp/table_store';
这个路径是flink的config的路径?
您能否提供一个完整的table sql 的demo么,我看官网是纯sql cli去提交的


陈卓宇


&nbsp;




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <jingsonglee0@gmail.com&gt;;
发送时间:&nbsp;2022年4月28日(星期四) 下午3:19
收件人:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

主题:&nbsp;Re: 对Flink Table Store咨询



哈喽,感谢你的关注

Tison是对的,Table Store是一个库。我们目前并没有发布maven依赖。

目前你可以有两种方式来调试:

1.在Table Store的工程里调试
2.在拿到flink-table-store-dist下的 pre bundled jar,放到你工程的classpath下来调试

入口类的话是通过SQL的方式:

TableEnvironment.executeSql("CREATE TABLE XX (...)");

当classpath下包含 table store 的 jar 时,会服务发现到 TableStore 的 factory,进而走到
table store 的代码。

你的需求是合理的,我们后续会考虑提供官方的maven依赖支持,且提供DataStream API

Best,
Jingsong

On Sun, Apr 24, 2022 at 10:32 AM tison <wander4096@gmail.com&gt; wrote:
&gt;
&gt; Flink Table Store 不是应用,而是库。我理解是要配合 Flink
&gt; 来使用的,断点调试的话,看你的需求,如果只是对一段代码有疑问,跑测试打断点就行了。
&gt;
&gt; Best,
&gt; tison.
&gt;
&gt;
&gt; 陈卓宇 <2572805166@qq.com.invalid&gt; 于2022年4月24日周日 09:59写道:
&gt;
&gt; &gt; 您好大佬:
&gt; &gt; &amp;nbsp;&amp;nbsp;&amp;nbsp;&amp;nbsp; 我对Flink Table
&gt; &gt; Store非常感兴趣,想请教您一下怎么结合flink做断点调试,因为看了一下没有找到入口类
&gt; &gt;
&gt; &gt; 陈卓宇
&gt; &gt;
&gt; &gt;
&gt; &gt; &amp;nbsp;

Re: 对Flink Table Store咨询

Posted by Jingsong Li <ji...@gmail.com>.
哈喽,感谢你的关注

Tison是对的,Table Store是一个库。我们目前并没有发布maven依赖。

目前你可以有两种方式来调试:

1.在Table Store的工程里调试
2.在拿到flink-table-store-dist下的 pre bundled jar,放到你工程的classpath下来调试

入口类的话是通过SQL的方式:

TableEnvironment.executeSql("CREATE TABLE XX (...)");

当classpath下包含 table store 的 jar 时,会服务发现到 TableStore 的 factory,进而走到
table store 的代码。

你的需求是合理的,我们后续会考虑提供官方的maven依赖支持,且提供DataStream API

Best,
Jingsong

On Sun, Apr 24, 2022 at 10:32 AM tison <wa...@gmail.com> wrote:
>
> Flink Table Store 不是应用,而是库。我理解是要配合 Flink
> 来使用的,断点调试的话,看你的需求,如果只是对一段代码有疑问,跑测试打断点就行了。
>
> Best,
> tison.
>
>
> 陈卓宇 <25...@qq.com.invalid> 于2022年4月24日周日 09:59写道:
>
> > 您好大佬:
> > &nbsp;&nbsp;&nbsp;&nbsp; 我对Flink Table
> > Store非常感兴趣,想请教您一下怎么结合flink做断点调试,因为看了一下没有找到入口类
> >
> > 陈卓宇
> >
> >
> > &nbsp;

Re: 对Flink Table Store咨询

Posted by tison <wa...@gmail.com>.
Flink Table Store 不是应用,而是库。我理解是要配合 Flink
来使用的,断点调试的话,看你的需求,如果只是对一段代码有疑问,跑测试打断点就行了。

Best,
tison.


陈卓宇 <25...@qq.com.invalid> 于2022年4月24日周日 09:59写道:

> 您好大佬:
> &nbsp;&nbsp;&nbsp;&nbsp; 我对Flink Table
> Store非常感兴趣,想请教您一下怎么结合flink做断点调试,因为看了一下没有找到入口类
>
> 陈卓宇
>
>
> &nbsp;