Github user bowenli86 commented on a diff in the pull request:
@@ -162,7 +162,7 @@ class GroupAggProcessFunction(
override def onTimer(
- ctx: ProcessFunction[CRow, CRow]#OnTimerContext,
+ ctx: ProcessFunction[CRow, CRow]#OnTimerContext[_],
--- End diff --
yes, I think I'll create a `KeyedProcessFunction` as Aljoscha suggested,
and we probably don't need these scala changes any more.