[jira] [Comment Edited] (FLINK-32650) Added the ability to split flink-protobuf codegen code

[ https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748873#comment-17748873 ] Suhan Mao edited comment on FLINK-32650 at 8/7/23 8:53 AM: --- [~

[jira] [Commented] (FLINK-32650) Added the ability to split flink-protobuf codegen code

[ https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748873#comment-17748873 ] Suhan Mao commented on FLINK-32650: --- [~lijingwei.5018] Thanks for opening this ticket

[jira] [Comment Edited] (FLINK-32650) Added the ability to split flink-protobuf codegen code

[ https://issues.apache.org/jira/browse/FLINK-32650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17748873#comment-17748873 ] Suhan Mao edited comment on FLINK-32650 at 7/30/23 3:10 AM:

[jira] [Commented] (FLINK-32008) Protobuf format throws exception with Map datatype

[ https://issues.apache.org/jira/browse/FLINK-32008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725197#comment-17725197 ] Suhan Mao commented on FLINK-32008: --- I think the error is related to corrupt data.  

[jira] [Commented] (FLINK-31944) Protobuf format throw com.google.protobuf.InvalidProtocolBufferException

[ https://issues.apache.org/jira/browse/FLINK-31944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725196#comment-17725196 ] Suhan Mao commented on FLINK-31944: --- I think the error is related to corrupt data. >

[jira] [Commented] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17655630#comment-17655630 ] Suhan Mao commented on FLINK-30093: --- [~laughingman7743] Thanks for your code. It looks

[jira] [Commented] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654308#comment-17654308 ] Suhan Mao commented on FLINK-30093: --- [~jamesmcguirepro] Thanks for your feedback, I'll

[jira] [Commented] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652696#comment-17652696 ] Suhan Mao commented on FLINK-30093: --- [~rmetzger]  Since this issue can be solved by th

[jira] [Commented] (FLINK-30093) [Flink SQL][Protobuf] CompileException when querying Kafka topic using google.protobuf.Timestamp

[ https://issues.apache.org/jira/browse/FLINK-30093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17636400#comment-17636400 ] Suhan Mao commented on FLINK-30093: --- [~rmetzger] Thanks for your findings! I did not

[jira] [Commented] (FLINK-29370) Protobuf in flink-sql-protobuf is not shaded

[ https://issues.apache.org/jira/browse/FLINK-29370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17607841#comment-17607841 ] Suhan Mao commented on FLINK-29370: --- [~libenchao]  What about removing all com.google.

[jira] [Commented] (FLINK-28765) Create a doc for protobuf format

[ https://issues.apache.org/jira/browse/FLINK-28765?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17576210#comment-17576210 ] Suhan Mao commented on FLINK-28765: --- [~hui.yang] It probably can work, you could try.

[jira] [Created] (FLINK-28765) Create a doc for protobuf format

Suhan Mao created FLINK-28765: - Summary: Create a doc for protobuf format Key: FLINK-28765 URL: https://issues.apache.org/jira/browse/FLINK-28765 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17444985#comment-17444985 ] Suhan Mao commented on FLINK-18202: --- I think [https://github.com/apache/flink/pull/143

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246418#comment-17246418 ] Suhan Mao edited comment on FLINK-18202 at 2/23/21, 5:12 AM: -

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246418#comment-17246418 ] Suhan Mao edited comment on FLINK-18202 at 2/23/21, 4:09 AM: -

[jira] [Comment Edited] (FLINK-19612) Support CUMULATE window table function in planner

[ https://issues.apache.org/jira/browse/FLINK-19612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250797#comment-17250797 ] Suhan Mao edited comment on FLINK-19612 at 12/17/20, 4:18 AM:

[jira] [Comment Edited] (FLINK-19612) Support CUMULATE window table function in planner

[ https://issues.apache.org/jira/browse/FLINK-19612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250797#comment-17250797 ] Suhan Mao edited comment on FLINK-19612 at 12/17/20, 4:18 AM:

[jira] [Commented] (FLINK-19612) Support CUMULATE window table function in planner

[ https://issues.apache.org/jira/browse/FLINK-19612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250797#comment-17250797 ] Suhan Mao commented on FLINK-19612: --- [~jark]  Hi, I'm interested in how we implement t

[jira] [Updated] (FLINK-20611) Support 2 phase local aggregate for window aggregate operation

[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Description: In our company, many jobs run with window aggregate and suffer from large amounts of int

[jira] [Updated] (FLINK-20611) Support 2 phase local aggregate for window aggregate operation

[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Summary: Support 2 phase local aggregate for window aggregate operation (was: Support mini batch for

[jira] [Updated] (FLINK-20611) Support mini batch for window aggregate operation

[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Description: Currently, mini batch does not support window aggregate. In our company, many jobs run w

[jira] [Updated] (FLINK-20611) Support mini batch for window aggregate operation

[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Description: Currently, mini batch does not support window aggregate. In our company, many jobs run w

[jira] [Updated] (FLINK-20611) Support mini batch for window aggregate operation

[ https://issues.apache.org/jira/browse/FLINK-20611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suhan Mao updated FLINK-20611: -- Component/s: Table SQL / Planner > Support mini batch for window aggregate operation > ---

[jira] [Created] (FLINK-20611) Support mini batch for window aggregate operation

Suhan Mao created FLINK-20611: - Summary: Support mini batch for window aggregate operation Key: FLINK-20611 URL: https://issues.apache.org/jira/browse/FLINK-20611 Project: Flink Issue Type: New F

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248936#comment-17248936 ] Suhan Mao commented on FLINK-18202: --- [~syucream] That is a good idea! I think "protobu

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17248805#comment-17248805 ] Suhan Mao commented on FLINK-18202: --- [~libenchao]. [~jark] I created a PR for this is

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246418#comment-17246418 ] Suhan Mao edited comment on FLINK-18202 at 12/9/20, 11:15 AM:

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246418#comment-17246418 ] Suhan Mao edited comment on FLINK-18202 at 12/9/20, 11:14 AM:

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246418#comment-17246418 ] Suhan Mao edited comment on FLINK-18202 at 12/9/20, 11:14 AM:

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246418#comment-17246418 ] Suhan Mao edited comment on FLINK-18202 at 12/9/20, 11:10 AM:

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246418#comment-17246418 ] Suhan Mao edited comment on FLINK-18202 at 12/9/20, 10:21 AM:

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246418#comment-17246418 ] Suhan Mao commented on FLINK-18202: --- I will give an introduction about 3 ways: 1.  Dyn

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235531#comment-17235531 ] Suhan Mao edited comment on FLINK-18202 at 11/19/20, 3:17 PM:

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235531#comment-17235531 ] Suhan Mao edited comment on FLINK-18202 at 11/19/20, 3:16 PM:

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235531#comment-17235531 ] Suhan Mao edited comment on FLINK-18202 at 11/19/20, 3:12 PM:

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235531#comment-17235531 ] Suhan Mao edited comment on FLINK-18202 at 11/19/20, 3:01 PM:

[jira] [Comment Edited] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235531#comment-17235531 ] Suhan Mao edited comment on FLINK-18202 at 11/19/20, 3:01 PM:

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235531#comment-17235531 ] Suhan Mao commented on FLINK-18202: --- [~twalthr] [~libenchao] I have finished the firs

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234445#comment-17234445 ] Suhan Mao commented on FLINK-18202: --- [~twalthr] Sure. It will be an honor to contribut

[jira] [Commented] (FLINK-18202) Introduce Protobuf format

[ https://issues.apache.org/jira/browse/FLINK-18202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17233527#comment-17233527 ] Suhan Mao commented on FLINK-18202: --- I have some experience and already implemented th