[ https://issues.apache.org/jira/browse/FLINK-24915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17447797#comment-17447797 ]
bx123 commented on FLINK-24915: ------------------------------- [~arvid] [#FLINK-5017] introduced StreamStatus support for this serializer, while it does not handle streamstatus when object is reused in method deserialize(StreamElement reuse, DataInputView source). And [#FLINK-1137] said object reuse is not support in current flink version. So I guess maybe this is why this problem not occur in production. Is this right? flink-1137 is implemented in 2015 and I am not sure the status about object reuse in current version. Can you help me on this issue? thanks! > StreamElementSerializer#deserialize(StreamElement reuse, DataInputView > source) forgets to handle tag == TAG_STREAM_STATUS > ------------------------------------------------------------------------------------------------------------------------- > > Key: FLINK-24915 > URL: https://issues.apache.org/jira/browse/FLINK-24915 > Project: Flink > Issue Type: Bug > Components: API / DataStream > Reporter: bx123 > Priority: Minor > Labels: pull-request-available > > when StreamElement is reused, we also have to handle tag == TAG_WATERMARK as > object reuse disabled do. > See also Flink-5017. -- This message was sent by Atlassian Jira (v8.20.1#820001)