I tend to not change the current behavior. For other framework(e.g. hadoop,
yarn),
the arguments after user jar are also parsed by user `main()`, not the
framework client.
Best,
Yang
tison 于2020年3月6日周五 下午10:55写道：
> Hi Jingsong,
>
> I think your propose is "--classpath can occur behind the jar
Hi Jingsong,
I think your propose is "--classpath can occur behind the jar file".
Generally speaking I agree on that it is a painful required format that
users tend to just ignore that order how an option occurs. So it is +1 from
my side to loose the constraint.
However, for the migration and im
I think tison's answer is on point. All the Flink cli options should be
specified before the user jar. We have a very clear help message.
Syntax: run [OPTIONS]
Best,
Yang
Jingsong Li 于2020年3月6日周五 下午10:27写道：
> Hi tison and Aljoscha,
>
> Do you think "--classpath can not be in front of jar fi
Hi tison and Aljoscha,
Do you think "--classpath can not be in front of jar file" is an
improvement? Or need documentation? Because I used to be confused.
Best,
Jingsong Lee
On Fri, Mar 6, 2020 at 10:22 PM tison wrote:
> I think the problem is that --classpath should be before the user jar,
>
It is because as implementation when we parse command line argument it
"stopAtNonOptions" at the arbitrary content user jar. All arguments later
will be regarded as args passed to user main.
For user serving, when you run `./bin/flink run -h`, it prints
Action "run" compiles and runs a program.
I think the problem is that --classpath should be before the user jar,
i.e., /opt/flink/job/kafkaDemo19-1.0-SNAPSHOT.jar
Best,
tison.
Aljoscha Krettek 于2020年3月6日周五 下午10:03写道：
> Hi,
>
> first a preliminary question: does the jar file contain
> com.alibaba.fastjson.JSON? Could you maybe list the
Hi ouywl,
As I know, "--classpath" should be in front of jar file, it means:
/opt/flink/bin/flink run --jobmanager ip:8081 --class
com.netease.java.TopSpeedWindowing --parallelism 1 --detached --classpath
file:///opt/flink/job/fastjson-1.2.66.jar
/opt/flink/job/kafkaDemo19-1.0-SNAPSHOT.jar
You ca
Hi,
first a preliminary question: does the jar file contain
com.alibaba.fastjson.JSON? Could you maybe list the contents of the jar
here?
Best,
Aljoscha
On 06.03.20 13:25, ouywl wrote:
Hi all
When I start a flinkcluster in session mode, It include jm/tm. And then I
submit a job like ‘
Hi all When I start a flinkcluster in session mode, It include jm/tm. And then I submit a job like ‘bin/flink run —jobmanager “ip:8081” —class path a.jar’. Even the a.jar in all jm/tm and ‘bin/flink’ mechine . It will throw exception “/opt/flink/bin/flink run --jobmanager ip:
