If I store the Java protobuf objects in the rocksdb instead of the scala
objects, I get this stacktrace:
2023-02-07 09:17:04,246 WARN org.apache.flink.runtime.taskmanager.Task
[] - KeyedProcess -> (Map -> Sink: signalSink, Map -> Flat
Map -> Sink: FeatureSink, Sink: logsink) (2/2)#
Hi, I have been struggling with this particular Exception for days and
thought I'd ask for help here.
I am using a KeyedProcessFunction with a
private lazy val state: ValueState[Feature] = {
val stateDescriptor = new
ValueStateDescriptor[Feature]("CollectFeatureProcessState",
createTypeInfo
