文章目录
- 1. 描述
- 2. 使用语法
- 3. `-C` 适用的 Flink 运行模式
- 4. USING JAR 不可用
1. 描述
Flink 中的-C选项用于将 URL 添加到作业的类加载器中。URL可以指向本地、HTTP 服务器或 HDFS 等资源的Jar文件。
注意：
- 此处的classpath的url必须是一个能够在client，JM和TM都被访问到的位置。
- 此位置从client端的提交到JM的分发到TM的访问的过程中，不会发生文件移动的动作。
- url支持的协议包括file,ftp,gopher,http,https,jar,mailto,netdoc，亦即java中URL类支持的协议类型。
- 注意：不能放在hdfs上。否则会报错：Bad syntax for classpath: hdfs://xxx。
2. 使用语法
flink run\-Chttp://home/user/flink-udf1.jar\-Chttp://home/user/flink-udf2.jar\-jjob.jar配置多个udf：每个-C选项只能对应一个 JAR，不能用逗号,分隔多个路径。
如下示例，
从Taskmanager日志可以看到成功加载https格式的jar包
url路径的结尾可以不以.jar结尾
3.-C适用的 Flink 运行模式
| 运行模式 | 是否支持-C |
|---|---|
| Standalone（独立模式） | ✅ 支持 |
| YARN Session | ✅ 支持 |
| YARN Per-job | ✅ 支持 |
| Kubernetes | ✅ 支持 |
| Local（本地模式） | ✅ 支持 |
4. USING JAR 不可用
使用Flink Sql加载udf
CREATEFUNCTIONmy_udfAS'com.example.MyUDF'USINGJAR'hdfs://namenode:9000/flink-udf.jar';报错：直接不可用。
org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue. at
