flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matt <dromitl...@gmail.com>
Subject [BUG?] Cannot Load User Class on Local Environment
Date Tue, 25 Apr 2017 05:27:14 GMT
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

Mime
View raw message