[
https://issues.apache.org/jira/browse/FLINK-5221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15724302#comment-15724302
]
shijinkui commented on FLINK-5221:
----------------------------------
This problem is Java low level API used Scala high level API's class, but Java
API haven't dependency Scala API. They are all added into same classpath,
otherwise it will have a class not found runtime exception.
We can add new interface function `getUserFunction` for return the useFunction
object.
In general, Flink Java API and Scala API，which one more suitable to as a low
level API. I think scala tait is better than Java interface.
[~till.rohrmann], do we have plan to have an unified API in the future, for
example 2.0?
> Checkpointed workless in Window Operator
> ----------------------------------------
>
> Key: FLINK-5221
> URL: https://issues.apache.org/jira/browse/FLINK-5221
> Project: Flink
> Issue Type: Bug
> Components: DataStream API
> Affects Versions: 1.2.0, 1.1.3
> Environment: SUSE
> Reporter: Syinchwun Leo
> Labels: windows
> Fix For: 1.2.0
>
> Original Estimate: 12h
> Remaining Estimate: 12h
>
> When window OPERATOR making checkpoint like this:
> class WindowStatistic extends WindowFunction[Event, Int, Tuple, TimeWindow]
> 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 AbstractUdfStreamOperator.java 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
(v6.3.4#6332)
