Github user bowenli86 commented on a diff in the pull request:
    --- Diff: 
    @@ -162,7 +162,7 @@ class GroupAggProcessFunction(
       override def onTimer(
           timestamp: Long,
    -      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.


Reply via email to