JAR 语句

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

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

  • ADD JAR
  • REMOVE JAR
  • SHOW JARS

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

执行 JAR 语句

SQL CLI

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

SQL CLI

  1. Flink SQL> ADD JAR '/path/hello.jar';
  2. [INFO] The specified jar is added into session classloader.
  4. Flink SQL> SHOW JARS;
  5. /path/hello.jar
  7. Flink SQL> REMOVE JAR '/path/hello.jar';
  8. [INFO] The specified jar is removed from session classloader.

ADD JAR

  1. ADD JAR '<path_to_filename>.jar'

目前只支持将本地 jar 添加到会话类类加载器（session classloader）中。

REMOVE JAR

  1. REMOVE JAR '<path_to_filename>.jar'

目前只支持删除 ADD JAR 语句添加的 jar。

SHOW JARS

  1. SHOW JARS

展示会话类类加载器（session classloader）中所有基于 ADD JAR 语句添加的 jar。