Hi all, I'm trying to run Flink using a local environment, but on an Ignite node to achieve collocation (as mentioned in my previous message on this list).
Have a look at the code in [1]. It's pretty simple, but I'm getting a "cannot load user class" error as shown in [2]. If you check line #29 on the code, I'm able to create an instance of class Test, and it's the same context from which I'm creating the Flink job. Shouldn't it work provided I'm using a local environment? It would be really nice to be able to inject a ClassLoader into the chunk of code that creates the job. Is this currently possible? Any fix or workaround is appreciated! Best, Matt [1] https://gist.github.com/f248187b9638023b95ba8bd9d7f06215 [2] https://gist.github.com/796ee05425535ece1736df7b1e884cce
