How heap state backend serialization happens during snapshotting

2021-08-26 Thread Muhammad Haseeb Asif
Hello, I have been trying to understand how serialization works for the Flink Heap Keyed state backend when a checkpoint happens. I want to know how Flink knows which type of serializer to use to serialize the values for different states during the snapshot. I have debugged both RocksDB and he

Re: Compilation error - Execution of spotless-check goal failed in flink-annotations project

2021-08-03 Thread Muhammad Haseeb Asif
Asif Subject: Re: Compilation error - Execution of spotless-check goal failed in flink-annotations project You are not using java 8, as shown by your maven output. We have not made sure yet that Flink can be built on Java 16. On 03/08/2021 12:00, Muhammad Haseeb Asif wrote: > I am trying

Compilation error - Execution of spotless-check goal failed in flink-annotations project

2021-08-03 Thread Muhammad Haseeb Asif
I am trying to build the Apache Flink project on my local machine and it seems like failing due to spotless issues. I am running the build on mac with java 8 xyz% java -version java version "1.8.0_301" Java(TM) SE Runtime Environment (build 1.8.0_301-b09) Java HotSpot(TM) 64-Bit Server VM (bu