Hi Yubraj,
The solution to a similar problem from StackOverflow is to explicitly
define the serialVersionUID in your class. For more information, please
visit here.[1]
[1]:
https://stackoverflow.com/questions/27647992/how-resolve-java-io-invalidclassexception-local-class-incompatible-stream-clas
it works , but now i am getting
org.apache.flink.streaming.runtime.tasks.StreamTaskException: Cannot
instantiate user function.
at
org.apache.flink.streaming.api.graph.StreamConfig.getStreamOperator(StreamConfig.java:239)
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.
Hi Yubraj Singh,
Can you try submitting with HADOOP_CLASSPATH=`hadoop classpath` set? [1]
For example:
HADOOP_CLASSPATH=`hadoop classpath` bin/flink run [...]
Best,
Gary
[1]
https://ci.apache.org/projects/flink/flink-docs-master/ops/deployment/hadoop.html#configuring-flink-with-hadoop-classpat
It's stage env for the company and other jobs are running on the same so I
can't change anything
Thanks
Yubraj Singh
On Tue, Aug 21, 2018, 9:31 PM Paul Lam wrote:
> Hi yuvraj,
>
> Please try turning off timeline server in yarn-site.xml. Currently Flink
> does not ship the required dependencies
Hi yuvraj,
Please try turning off timeline server in yarn-site.xml. Currently Flink does
not ship the required dependencies for timeline server, which I think could be
a bug.
Best Regards,
Paul Lam
> 在 2018年8月21日，22:23，yuvraj singh <19yuvrajsing...@gmail.com> 写道：
>
> Hi ,
>
> i am getting a
Hi ,
i am getting a error while running a flink job on yarn cluster , its
running fine when i run it on flink standalone cluster
java.lang.NoClassDefFoundError:
com/sun/jersey/core/util/FeaturesAndProperties
at java.lang.ClassLoader.defineClass1(Native Method)
at java.lang.ClassLoader.defineCla
