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/common/index.html#rich-functions
Cheers, Aljoscha On Sat, 11 Jun 2016 at 21:07 Vinay Patil <[email protected]> wrote: > 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 implements MapFunction<String, List<String>> { > private static TempClass tempClass; > > public App() { > tempClass = new TempClass(); > } > > @Override > public List<String> map(String dummyString) throws Exception { > *tempClass.doSomething(dummyString); // getting NPE here* > } > } > > I am not getting NPE when I run it on a single machine, however when I run > on a cluster , it gives me NPE. > Instantiating tempClass inside the map function will fix the issue , > however my reviewer suggested not to initialize it inside the operator as > it will get initialized always, so did it in the constructor. > > > Also, when I looked at the flink examples, you have used static classes and > accessed the functions inside operators, so which is the better approach > instantiating inside the operators or use static class ? > > > > Regards, > Vinay Patil > > *+91-800-728-4749* > > On Sat, Jun 11, 2016 at 9:32 AM, Vinay Patil <[email protected]> > wrote: > > > 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 pom we are using > > > > Regards, > > Vinay Patil > > > > *+91-800-728-4749* > > > > On Sat, Jun 11, 2016 at 1:36 AM, Robert Metzger <[email protected]> > > wrote: > > > >> 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 <[email protected]> > >> wrote: > >> > >> > How did you “provide” the dependencies? Did you use the –C <URL> > >> > parameter when you submitted your job? > >> > > >> > On 6/10/16, 11:35 AM, "Vinay Patil" <[email protected]> wrote: > >> > > >> > >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 > >> > > >> > > >> > > > > >
