[
https://issues.apache.org/jira/browse/FLINK-7627?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16210588#comment-16210588
]
ASF GitHub Bot commented on FLINK-7627:
---------------------------------------
Github user hequn8128 commented on the issue:
https://github.com/apache/flink/pull/4674
hi, @fhueske
I was using sliding window and `NotSerializableException` was thrown when
doing incremental snapshot. This can be fixed by implementing
`SingleElementIterable` with `Serializable`.
This problem may only exists in our internal flink but i am not sure
considering that I am unfamiliar with runtime part. In our internal flink,
`InternalStateDescriptor` will be serialized which lead to the
`NotSerializableException`, however I can't find the same logic in flink. I
tried to write checkpoint tests to reproduce the problem but failed. It will be
very grateful if you can give me some advice to figure it out.
Thanks, Hequn
> SingleElementIterable should implement with Serializable
> ---------------------------------------------------------
>
> Key: FLINK-7627
> URL: https://issues.apache.org/jira/browse/FLINK-7627
> Project: Flink
> Issue Type: Bug
> Components: Table API & SQL
> Reporter: Hequn Cheng
> Assignee: Hequn Cheng
>
> {{SingleElementIterable}} is used to merge accumulators and it should be
> serializable considering that it will be serialized when doing checkpoint.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
