Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
Description
FLINK-5801 shows a very hard to debug issue when querying state from the Scala API that can result in serializer mismatches between the client and the job.
We should mention that the type serializers should be created via the Scala macros.
import org.apache.flink.streaming.api.scala._ ... val keySerializer = createTypeInformation[Long].createSerializer(new ExecutionConfig)