[jira] [Commented] (FLINK-21005) Introduce new provider for unified Sink API and implement in planner

2021-01-18 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17267062#comment-17267062 ] huajiewang commented on FLINK-21005: please assign to me > Introduce new provider for unified Sink

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-15 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265817#comment-17265817 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 8:39 AM: --

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-15 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265817#comment-17265817 ] huajiewang commented on FLINK-20972: [~gaoyunhaii] What you said is reasonable, but in my opinion,

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:29 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265737#comment-17265737 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:27 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265737#comment-17265737 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:25 AM: -- Hi

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265737#comment-17265737 ] huajiewang commented on FLINK-20972: Hi [~gaoyunhaii] i can overwrite toString method for my 

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:20 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:19 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:18 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:18 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:18 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:17 AM: -- Hi

[jira] [Comment Edited] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang edited comment on FLINK-20972 at 1/15/21, 6:16 AM: -- Hi

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17265732#comment-17265732 ] huajiewang commented on FLINK-20972: u are right, my Transaction class is here: scala:  

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: in TwoPhaseCommitSinkFunctionOutput Maybe A large number of EventData will be

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: in TwoPhaseCommitSinkFunctionOutput Maybe A large number of EventData will be

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Attachment: 1610682603148.jpg > TwoPhaseCommitSinkFunction Output a large amount of EventData >

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Attachment: 1610682498960.jpg > TwoPhaseCommitSinkFunction Output a large amount of EventData >

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: in TwoPhaseCommitSinkFunctionOutput Maybe A large number of EventData will be

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Commented] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17264793#comment-17264793 ] huajiewang commented on FLINK-20972: yes! > TwoPhaseCommitSinkFunction Output a large amount of

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Description: when TwoPhaseCommitSinkFunctionOutput tigger notifyCheckpointComplete, Maybe A large

[jira] [Updated] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] huajiewang updated FLINK-20972: --- Attachment: Jdbc2PCSinkFunction.scala > TwoPhaseCommitSinkFunction Output a large amount of

[jira] [Created] (FLINK-20972) TwoPhaseCommitSinkFunction Output a large amount of EventData

2021-01-14 Thread huajiewang (Jira)
huajiewang created FLINK-20972: -- Summary: TwoPhaseCommitSinkFunction Output a large amount of EventData Key: FLINK-20972 URL: https://issues.apache.org/jira/browse/FLINK-20972 Project: Flink