I Have solve this problem , thanks.
LakeShen <
[hidden email]> 于2019年8月27日周二 下午4:55写道：
> Hi community ， I have a question about flink command, when I use flink run
> command to submit my flink job to yarn , I use -yt to upload my function
> jar , but I set -C file:xxxfunction.jar , the flink job throw the exception
> like this :
> The main method caused an error: Could not find class
> 'com.youzan.bigdata.HashCode' for creating an instance.
> stderr> at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:593)
> stderr> at
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:438)
> stderr> at
> org.apache.flink.client.program.OptimizerPlanEnvironment.getOptimizedPlan(OptimizerPlanEnvironment.java:83)
> stderr> at
> org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:80)
> stderr> at
> org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:122)
> stderr> at
> org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:227)
> stderr> at
> org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:205)
> stderr> at
> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1010)
> stderr> at
> org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1083)
> stderr> at java.security.AccessController.doPrivileged(Native Method)
> stderr> at javax.security.auth.Subject.doAs(Subject.java:422)
> stderr> at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1692)
> stderr> at
> org.apache.flink.runtime.security.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:
>
> When I set -yt to upload my Function jar , what value will I set -C
> parameters? Thanks.
>
Locked
