You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by chenxuying <cx...@163.com> on 2020/06/24 10:13:26 UTC

flink REST API是否支持-C参数

目前使用的是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 /usr/local/soft/flink/flink-1.0-SNAPSHOT.jar
    可以看到命令行方式支持-C提供另外的jar包,flink会加载到classpath
问题:
    发现目前的restapi并没有提供想命令行一样的-C参数的功能 , 所以想知道这个功能将来是否会增加

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

Posted by Yang Wang <da...@gmail.com>.

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 <cx...@163.com> 于2020年6月24日周三 下午6:13写道：

> 目前使用的是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
> /usr/local/soft/flink/flink-1.0-SNAPSHOT.jar
>     可以看到命令行方式支持-C提供另外的jar包,flink会加载到classpath
> 问题:
>     发现目前的restapi并没有提供想命令行一样的-C参数的功能 , 所以想知道这个功能将来是否会增加