Package org.apache.flink.table.api.runtime.types

Class FlinkScalaKryoInstantiator

java.lang.Object

org.apache.flink.table.api.runtime.types.FlinkScalaKryoInstantiator

public class FlinkScalaKryoInstantiator
extends Object

Override Flink's internal FlinkScalaKryoInstantiator to avoid loading the Scala extensions for the KryoSerializer. This is a workaround until Kryo-related issues with the Scala extensions are fixed. See: https://issues.apache.org/jira/browse/FLINK-37546

Constructor Summary

Constructors

Constructor	Description
FlinkScalaKryoInstantiator()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FlinkScalaKryoInstantiator

public FlinkScalaKryoInstantiator()