请教一下,如何使用 Zeppelin 编写 FlinkSQL并且执行看结果呢(就像SQLClient那样),我找了一些资料,只找到使用Scala的: https://zeppelin.apache.org/docs/0.8.0/interpreter/flink.html
顺便问一下,我现在已经写了一些代码用来初始化 StreamEnvironment 以及 TableEnvironment,我如何将这些初始化的代码用到 Flink SQL Client 中呢(而不是使用配置文件初始化表环境)?我尝试在Flink的工程中引入 Flink SQL Client的maven包,并且以 minimal cluster 模式启动,但是无法执行。 在 2019-03-04 10:34:27,"Fei Han" <hanfeizi0...@aliyun.com.INVALID> 写道: >你好! > sql-client你现在可以在zeepelin上去写SQL,但只支持DML,DDL暂时 > 还不支持(如 create table) > > Best, > Han Fei > > > > >------------------------------------------------------------------ >发件人:yuess_coder <642969...@qq.com> >发送时间:2019年3月4日(星期一) 10:29 >收件人:user-zh@flink.apache.org <user-zh@flink.apache.org> >主 题:sql-client 支持远程连接flink集群吗 > >如题 >