JAR 语句

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

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

  • ADD JAR
  • SHOW JARS
  • REMOVE JAR

执行 JAR 语句

SQL CLI

以下示例展示了如何在 SQL CLI 中运行 JAR 语句。

SQL CLI

  1. Flink SQL> ADD JAR '/path/hello.jar';
  2. [INFO] Execute statement succeed.
  4. Flink SQL> ADD JAR 'hdfs:///udf/common-udf.jar';
  5. [INFO] Execute statement succeed.
  7. Flink SQL> SHOW JARS;
  8. +----------------------------+
  9. |                       jars |
  10. +----------------------------+
  11. |            /path/hello.jar |
  12. | hdfs:///udf/common-udf.jar |
  13. +----------------------------+
  15. Flink SQL> REMOVE JAR '/path/hello.jar';
  16. [INFO] The specified jar is removed from session classloader.

ADD JAR

  1. ADD JAR '<path_to_filename>.jar'

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

限制

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

SHOW JARS

  1. SHOW JARS

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

REMOVE JAR

  1. REMOVE JAR '<path_to_filename>.jar'

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

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