Re: [Issue] No Class Definition Found Error

2016-06-12 Thread Vinay Patil
Yes correct. Thank you for this suggestion. This is the first time I am working on distributed application, so having such basic questions Now I am getting object is not serializable exception. I have generated the serialUId for that class. On Jun 12, 2016 11:28 AM, "Aljoscha Krettek" wrote: >

Re: [Issue] No Class Definition Found Error

2016-06-11 Thread Aljoscha Krettek
Hi, the static field will be null after the code has been shipped to the cluster. You can use a RichMapFunction instead, there you can define an open() method to initialize such a field. Please see this part of the doc for rich functions: https://ci.apache.org/projects/flink/flink-docs-master/apis/

Re: [Issue] No Class Definition Found Error

2016-06-11 Thread Vinay Patil
Issue resolved. Created the uber jar (fat jar) as shown in the flink-quickstart guide. My bad, I should have checked that first. However now I am facing NullPointerException , consider the following example (this is the dummy code , since I cannot share the actual code): public class App impleme

Re: [Issue] No Class Definition Found Error

2016-06-10 Thread Vinay Patil
Hi Robert, Yes we are using maven for building the jar, I have deployed both jar with dependencies and without dependencies. I actually cannot share the pom since it is on the client machine. But all the dependencies required are there, I have attached a sample pom file which is similar to the p

Re: [Issue] No Class Definition Found Error

2016-06-10 Thread Robert Metzger
Are you using Maven for building your job jar? If yes, can you post your pom file on the mailing list? On Fri, Jun 10, 2016 at 7:16 PM, THORMAN, ROBERT D wrote: > How did you “provide” the dependencies? Did you use the –C > parameter when you submitted your job? > > On 6/10/16, 11:35 AM, "Vina

Re: [Issue] No Class Definition Found Error

2016-06-10 Thread THORMAN, ROBERT D
How did you “provide” the dependencies? Did you use the –C parameter when you submitted your job? On 6/10/16, 11:35 AM, "Vinay Patil" wrote: >Hi Guys, > >I have deployed my application on a cluster, however when I try to run the >application it throws *NoClassDefFoundError for KeyedDeserializ

[Issue] No Class Definition Found Error

2016-06-10 Thread Vinay Patil
Hi Guys, I have deployed my application on a cluster, however when I try to run the application it throws *NoClassDefFoundError for KeyedDeserializationSchema*, all the dependencies are provided correctly since I have run it on a different standalone node. Please Help Regards, Vinay Patil