Syinchwun Leo created FLINK-5221:

             Summary: Checkpointed workless in Window Operator
                 Key: FLINK-5221
             Project: Flink
          Issue Type: Bug
          Components: DataStream API
    Affects Versions: 1.1.3
         Environment: SUSE
            Reporter: Syinchwun Leo

When window OPERATOR making checkpoint like this:

class WindowStatistic  extends WindowFunction[Event, Int, Tuple, TineWindow] 
with CHeckpointed[Option[List[Event]]] {
    override def appley()....
    override def snapshotState()...
    override def restoreState()

Window Operator couldn't invoke user defined function "snapshotState()". In 
debug model, line 123 in returns false and can't 
make user defined state when checking the window whether is a Checkpointed 
instance. I think there is something wrong in userFunction var, it's a 
ScalaWindowFunctionWrapper object and it couldn't reflect if the user defined 
window extend Checkpointed Interface. Actually, the user defined window is kept 
in "func" var of userFunction. 

This message was sent by Atlassian JIRA

Reply via email to