跳到主要内容
版本: 1.1

EXECUTE JAR

背景

该功能是为了解决在执行 JAR 类型任务时，去除各种繁杂交互, 以及统一任务提交方式, 使得用户可以更加方便的提交任务。

注意事项

如果使用 Checkpoint 或 Savepoint ,请在右边作业，选择 Savepoint策略，其次检查点 跳过 请使用 execution.savepoint.ignore-unclaimed-state: true 参数控制

此flink sql jar任务支持 set 和 add customjar 联动使用

语法结构​


EXECUTE JAR WITH (
'uri'='<jar_path>.jar', -- 该参数 必填
'main-class'='<main_class>', -- 该参数 必填
'args'='<args>' -- 主类入参 该参数可选 
);

Jar包任务提交 Demo:​

EXECUTE JAR WITH (
'uri'='rs:/jar/flink/demo/SocketWindowWordCount.jar',
'main-class'='org.apache.flink.streaming.examples.socket.SocketWindowWordCount',
'args'=' --hostname localhost '
);
注意
  1. 以上示例中, uri 的值为 rs:/jar/flink/demo/SocketWindowWordCount.jar, 该值为资源中心中的资源路径, 请确保资源中心中存在该资源,请忽略资源中心 Root 节点(该节点为虚拟节点)
  2. 如果要读取S3，HDFS，LOCAL等存储上面的文件均可通过rs协议进行桥接使用,请参考 资源管理 中 rs 协议使用方式
EXECUTE JAR WITH (
'uri'='rs:/test_flink.py',
'main-class'='org.apache.flink.client.python.PythonDriver',
'args'=''
);
注意
  1. 以上示例中, main-class 的值为 org.apache.flink.client.python.PythonDriver, 该值为 Python 的必填值和固定值