[jira] [Created] (FLINK-25127) Reuse a single Collection in GlobalWindows#assignWindows

2021-12-01 Thread bx123 (Jira)
bx123 created FLINK-25127: - Summary: Reuse a single Collection in GlobalWindows#assignWindows Key: FLINK-25127 URL: https://issues.apache.org/jira/browse/FLINK-25127 Project: Flink Issue Type: Improv

[jira] [Commented] (FLINK-24915) StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS

2021-11-22 Thread bx123 (Jira)
[ 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

[jira] [Created] (FLINK-24994) WindowedStream#reduce(ReduceFunction function) gives useless suggestion when reducefunction is richfunction.

2021-11-22 Thread bx123 (Jira)
bx123 created FLINK-24994: - Summary: WindowedStream#reduce(ReduceFunction function) gives useless suggestion when reducefunction is richfunction. Key: FLINK-24994 URL: https://issues.apache.org/jira/browse/FLINK-24994

[jira] [Commented] (FLINK-24915) StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS

2021-11-19 Thread bx123 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24915?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17446472#comment-17446472 ] bx123 commented on FLINK-24915: --- [~jark] , I have made the pr and can you assign this to m

[jira] [Created] (FLINK-24925) SingleThreadAccessCheckingTypeSerializer#equals() evaluates wrong field.

2021-11-16 Thread bx123 (Jira)
bx123 created FLINK-24925: - Summary: SingleThreadAccessCheckingTypeSerializer#equals() evaluates wrong field. Key: FLINK-24925 URL: https://issues.apache.org/jira/browse/FLINK-24925 Project: Flink I

[jira] [Created] (FLINK-24915) StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS

2021-11-15 Thread bx123 (Jira)
bx123 created FLINK-24915: - Summary: StreamElementSerializer#deserialize(StreamElement reuse, DataInputView source) forgets to handle tag == TAG_STREAM_STATUS Key: FLINK-24915 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-24895) SqlTimestampSerializer#deserialize forgets to fully read from source when the record is null.

2021-11-15 Thread bx123 (Jira)
bx123 created FLINK-24895: - Summary: SqlTimestampSerializer#deserialize forgets to fully read from source when the record is null. Key: FLINK-24895 URL: https://issues.apache.org/jira/browse/FLINK-24895 Proje

[jira] [Created] (FLINK-24879) ReducingStateDescriptor Constructor forgets to check ReduceFunction instanceof RichFunction

2021-11-11 Thread bx123 (Jira)
bx123 created FLINK-24879: - Summary: ReducingStateDescriptor Constructor forgets to check ReduceFunction instanceof RichFunction Key: FLINK-24879 URL: https://issues.apache.org/jira/browse/FLINK-24879 Project

[jira] [Commented] (FLINK-24797) GlobalWindow.Serializer#getLength() provides a wrong length.

2021-11-05 Thread bx123 (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17439248#comment-17439248 ] bx123 commented on FLINK-24797: --- PS: org.apache.flink.streaming.api.windowing.windows.Tim

[jira] [Created] (FLINK-24797) GlobalWindow.Serializer#getLength() provides a wrong length.

2021-11-05 Thread bx123 (Jira)
bx123 created FLINK-24797: - Summary: GlobalWindow.Serializer#getLength() provides a wrong length. Key: FLINK-24797 URL: https://issues.apache.org/jira/browse/FLINK-24797 Project: Flink Issue Type: B