the error it the original message means that inside a Kryo serializer, there is 
something that uses sun.misc.Unsafe to compute field offset in raw memory to 
access class fields. The problem is that memory layout in JVM and in NI is 
different and most probably will result in a segfault if you leave it as is.

If you really want to go further, there is a @RecomputeFieldValue(kind = 
Kind.FieldOffset) annotation in the graalvm to update the offset for NI.

But I guess the overall perspective of running Flink as a NI is not that good 
for the following reasons:
* GraalVM NI requires that the whole application is completely static and there 
is no dynamic classloading happening in runtime. NI still can handle some sort 
of dynamic classloading, but only if you define all possible combinations of 
loaded classes on compile time. Flink itself uses dynamic classloading when you 
submit a job there as a fat jar file. So you will need to statically compile a 
bundle of your app fat jar AND taskmanager code at once into a single binary.
* Flink also relies quite a lot on dynamic reflection in the serialization 
code, so you also have to build static reflection configuration at compile-time 
(by probably running your job+taskmanager with tracing agent on JVM)
* As GraalVM NI has no way of doing JIT compilation (as everything must be 
compiled statically), you should expect a lower overall job performance.

GraalVM and Flink can be quite a nice code gymnastics exercise, but what is 
your final business goal?

Roman Grebennikov | g...@dfdx.me

On Thu, Jun 25, 2020, at 11:48, ivo.kn...@t-online.de wrote:
> Whats up guys,


> I'm trying to run an Apache Flink Application with the GraalVM Native Image 
> but I get the following error: (check attached file)


> I suppose this happens, because Flink uses a lot of low-level-code and is 
> highly optimized.


> When I googled the combination of GraalVM Native Image and Apache Flink I get 
> no results.


> Did anyone ever succeeded in making it work and how?


> Best regards,


> Ivo

> *Attachments:*
>  * Flink GraalVM Native Image Error

Reply via email to