有没有办法使用 SQL 一个 运行 Flink 作业来查询
Is there a way to query using SQL a running Flink job
我是 Flink 的新手,正在尝试创建一个可以进行连续查询和按需查询的原型。第一部分已经工作(使用预定义的查询),但在第二部分中遇到困难。可以使用 SQL CLI。但是,我们希望能够从 Web 端点执行此操作。
我看过 Flink Jupyter notebook 集成,它告诉我这应该可以通过 Web 界面以某种方式工作。但是,不确定如何在每次不提交整个 JAR 的情况下执行此操作。
到目前为止,我的研究广泛地引导我找到了这两个资源:
有一个未完成的请求来实现它。参见 https://cwiki.apache.org/confluence/display/FLINK/FLIP-24+-+SQL+Client and https://cwiki.apache.org/confluence/display/FLINK/FLIP-91%3A+Support+SQL+Client+Gateway
有一个开源 JDBC 驱动程序(还没有尝试过)- https://github.com/ververica/flink-jdbc-driver - 不确定它是否得到维护并说“这个项目处于早期阶段舞台”。
关于我们还可以探索什么的任何建议?
目前Flink本身不支持。 Ververica Platform 提供了 SQL 个客户端,它也可以作为社区版使用。参见 https://www.ververica.com/apache-flink-sql-on-ververica-platform
我认为你可以使用 zeppelin 来 运行 Flink SQL。
还有其他 open-source Flink SQL 开发项目,例如Dlink.
我是 Flink 的新手,正在尝试创建一个可以进行连续查询和按需查询的原型。第一部分已经工作(使用预定义的查询),但在第二部分中遇到困难。可以使用 SQL CLI。但是,我们希望能够从 Web 端点执行此操作。
我看过 Flink Jupyter notebook 集成,它告诉我这应该可以通过 Web 界面以某种方式工作。但是,不确定如何在每次不提交整个 JAR 的情况下执行此操作。
到目前为止,我的研究广泛地引导我找到了这两个资源:
有一个未完成的请求来实现它。参见 https://cwiki.apache.org/confluence/display/FLINK/FLIP-24+-+SQL+Client and https://cwiki.apache.org/confluence/display/FLINK/FLIP-91%3A+Support+SQL+Client+Gateway
有一个开源 JDBC 驱动程序(还没有尝试过)- https://github.com/ververica/flink-jdbc-driver - 不确定它是否得到维护并说“这个项目处于早期阶段舞台”。
关于我们还可以探索什么的任何建议?
目前Flink本身不支持。 Ververica Platform 提供了 SQL 个客户端,它也可以作为社区版使用。参见 https://www.ververica.com/apache-flink-sql-on-ververica-platform
我认为你可以使用 zeppelin 来 运行 Flink SQL。
还有其他 open-source Flink SQL 开发项目,例如Dlink.