JAR Statements

JAR 语句 #

JAR 语句用于将用户 jar 添加到 classpath、或将用户 jar 从 classpath 中删除或展示运行时 classpath 中添加的 jar。

目前 Flink SQL 支持以下 JAR 语句：

  • ADD JAR
  • SHOW JARS
  • REMOVE JAR

执行 JAR 语句 #

以下示例展示了如何在 SQL CLI 中运行 JAR 语句。
Flink SQL> ADD JAR '/path/hello.jar';
[INFO] Execute statement succeed.

Flink SQL> ADD JAR 'hdfs:///udf/common-udf.jar';
[INFO] Execute statement succeed.

Flink SQL> SHOW JARS;
+----------------------------+
|                       jars |
+----------------------------+
|            /path/hello.jar |
| hdfs:///udf/common-udf.jar |
+----------------------------+

Flink SQL> REMOVE JAR '/path/hello.jar';
[INFO] The specified jar is removed from session classloader.

ADD JAR # 

ADD JAR '<path_to_filename>.jar'

添加一个 JAR 文件到资源列表中，该 jar 应该位于 Flink 当前支持的本地或远程文件系统 中。添加的 JAR 文件可以使用 SHOW JARS 语句列出。

限制 #

请不要通过 ADD JAR 语句来加载 Hive 的source、sink、function、catalog。这是 Hive connector 的一个已知限制，且会在将来版本中修复。当前，建议跟随这个指南来安装 Hive 的集成。

SHOW JARS # 

SHOW JARS

展示所有通过 ADD JAR 语句添加的 jar。

REMOVE JAR # 

REMOVE JAR '<path_to_filename>.jar'

删除由 ADD JAR 语句添加的指定 jar。

注意 REMOVE JAR 语句仅适用于 SQL CLI。

Back to top