A Flink program is typically packaged as an 'uber-jar' containing its dependencies. The Flink quickstart project illustrates this (see the use of the shading plugin in pom.xml). Based on your description, the classes of mylib2.jar were copied into mylib1.jar when the latter was built. Try rebuilding mylib1.jar to effect the change.
-Eron On Mon, Jul 31, 2017 at 11:18 AM, Mike Accola <macc...@us.ibm.com> wrote: > Are classes cached somewhere in flink? I am running in a very basic, > local environment on Linux (start_local.sh). I've somehow gotten my > environment into a strange state that I don't understand. I feel like I > am overlooking something simple, but I've checked everything I can think > of. > > My main flink application with a ProcessFunction is embedded in > mylib1.jar. Within my ProcessFunction I use another class that is > embedded in mylib2.jar. > > When I made changes to function in mylib2.jar and rebuilt the jar, I > realized the changes weren't taking affect. In fact, I then delete > mylib2.jar entirely and my application still worked. I can't figure out > where my application is picking up the function contained in mylib2.jar. I > have checked any temp directories, library paths, etc. I have repeatedly > stopped/started my flink environment just to be safe. > > I tried adding -verbose:class to env.java.opts. It output a lot of class > loading info to the stdout log, but there were no references to my class > in mylib2.jar. > > This has to be caching this code somehow whether it is in flink or in the > jvm. Any ideas what could be happening or how to debug this further? > > Thanks > > >
