git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

What is the right way to add classpath?


Hi,all

  My program needs some dependencies before it’s submitted to yarn. Like:

  ```

  stream.filter(new FilterService()).print()

  env.execute()

  ```

  I use external dependency in FilterService, and the program reports NoClassDefFoundError at     

  org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:529)


  Now my solution is changing the bin/flink and add my classpath into it.

  Any better ideas?

  Thanks.


  Best, Jiayi Liao