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


Reply via email to