Hi Burak,
It seems the variable you have in the unit test has incorrect type or it is
not fully compatible:
this variable --> stateDesc
found : org.apache.flink.api.common.state.ListStateDescriptor[(String,
Long)]
required: org.apache.flink.api.common.state.StateDescriptor[
_ <: org.
Hi,
I have a very basic window function that finds minimum and maximum values on a
keyed stream.
```
package org.example
import org.apache.flink.streaming.api.scala.function.ProcessWindowFunction
import org.apache.flink.streaming.api.windowing.windows.TimeWindow
import org.apache.flink.util.Col
