Re: flink REST API是否支持-C参数

2020-06-27 文章 Yang Wang
Flink CLI是把-C的参数apply到了client端生成的JobGraph里,然后提交JobGraph来运行的 使用Rest方式提交,目前确实不支持针对单个Job设置classpath,我觉得这是一个合理的需求,可以提个JIRA 目前work around的办法只能是配置到cluster的configuration里面,在启动session的时候使用-C/--classpath 或者-D pipeline.classpaths=xxx,yyy,这样所有的job都会把它们增加到classpath里了 Best, Yang chenxuying 于2020年6月24日周三

flink REST API是否支持-C参数

2020-06-24 文章 chenxuying
目前使用的是flink 1.10.0 背景: REST API有一个提交job的接口 接口 /jars/:jarid/run 参数entryClass,programArgs,parallelism,jobId,allowNonRestoredState,savepointPath 如果使用命令行方式提交job flink run -C file:///usr/local/soft/flink/my-function-0.1.jar -c cn.xuying.flink.table.sql.ParserSqlJob