Install
Last updated
Was this helpful?
Last updated
Was this helpful?
Glink 基于 Flink 1.12.x 版本进行扩展,在使用 Glink 之前需要先安装 Flink 1.12.x,并将 Glink 的相关 Jar 包复制到 Flink 的 classpath 路径下。Flink 的安装这里不再赘述,只讲述如何配置 Glink 所需的依赖。
Glink 目前仅支持从源码编译安装,首先下载Flink源码。
编译源码。
编译完成后在 glink-dist/target
目录下会生成一个安装包 glink-0.2-SNAPSHOT-bin.tar.gz
。解压后目录结构如下:
其中 Glink 的相关依赖均在 jar
文件夹下。通过如下命令复制到 $FLINK_HOME/lib
目录下。
Glink SQL 可配合 Apache Zepplin 使用,在使用前需先配置 Flink on Zepplin。在 Zepplin 中使用 Glink SQL 与直接使用 Flink SQL 的方法是相同的,关于具体如何配置和使用请参考 。这里只讲述如何在 Zepplin 中快速配置 Glink 所需的相关依赖。如果相关 Jar 包依赖已经在上述步骤中完成配置则不需要重复配置。
如果需要在 Zepplin 中使用 Glink 扩展的 SQL Connecter,需要将相关的 Jar 包放置在 Flink 的 classpath 路径下,最简单的方法是将所需 Connecter 的 Jar 包下载到 $FLINK_HOME/lib
目录下,并重启Flink集群。
Maven dependency
Jar file
glink-connecter-geomesa
glink-connector-geomesa-x.x.x.jar
如果需要在 Zepplin 中使用 Glink 提供的 Spatial SQL 函数,需要将如下 Jar 包放置在 Flink 的 classpath 路径下,最简单的方法是将下述 Jar 包下载到 $FLINK_HOME/lib
目录下,并重启Flink集群。
Maven dependency
Jar file
glink-sql
glink-sql-x.x.x.jar
此外,需要在 Zepplin 的 Flink Interpreter 中添加如下配置。
Name
Value
flink.udf.jars
$FLINK_HOME/lib/glink-sql-x.x.x.jar
flink.udf.jars.packages
com.github.tm.glink.sql.udf