[jira] [Created] (FLINK-5416) Function wrappers should support CheckpointedFunction

[Shang Yuanchun (Jira)]

Eron Wright  created FLINK-5416:
-----------------------------------

             Summary: Function wrappers should support CheckpointedFunction
                 Key: FLINK-5416
                 URL: https://issues.apache.org/jira/browse/FLINK-5416
             Project: Flink
          Issue Type: Bug
          Components: State Backends, Checkpointing
            Reporter: Eron Wright



The `CheckpointedFunction` interface was introduced to provide user functions with a context for partitioned state storage.   This works for user functions that are provided directly to the operator (assuming it extends from `AbstractUdfStreamOperator`).   However, I see that some operators wrap the user function in an internal function (e.g. `WrappingFunction`,  `InternalWindowFunction`).   This defeats the callbacks on `CheckpointedFunction` because those wrappers don’t implement `CheckpointedFunction`.

For example, the user function passed to `WindowedStream::apply` will get callbacks for `RichFunction` but not for `CheckpointedFunction`.





--
This message was sent by Atlassian JIRA
(v6.3.4#6332)