Hi All

org.apache.flink.runtime.types.FlinkScalaKryoInstantiator

is not available in the classpath for the specified version of Flink under

flink-runtime-1.18.1

I found

org.apache.flink.runtime.types.FlinkScalaKryoInstantiator

folder is present till dependency groupIdorg.apache.flink/groupId artifactIdflink-runtime_2.12/artifactId version1.13.6/version scopetest/scope /dependency After version upgrade to 1.18.1 this class is no longer available. and Getting runtime exception- _java.lang.ClassNotFoundException_: org.apache.flink.runtime.types.FlinkScalaKryoInstantiator at java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641) at java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188) at java.base/java.lang.ClassLoader.loadClass(ClassLoader.java:525) at java.base/java.lang.Class.forName0(Native Method) at java.base/java.lang.Class.forName(Class.java:375) I debugged the code found its throwing an error on

def convertTableToDatastream(table: Table, tableEnv: StreamTableEnvironment): DataStream[_] = {
  tableEnv.toDataStream(table)
}

Please suggest!!