[
https://issues.apache.org/jira/browse/FLINK-21005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267062#comment-17267062
]
huajiewang commented on FLINK-21005:
please assign to me
> Introduce new provider f
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265817#comment-17265817
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 8:39 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265817#comment-17265817
]
huajiewang commented on FLINK-20972:
[~gaoyunhaii] What you said is reasonable, but
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265732#comment-17265732
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:29 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265737#comment-17265737
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:27 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265737#comment-17265737
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:25 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265737#comment-17265737
]
huajiewang commented on FLINK-20972:
Hi [~gaoyunhaii] i can overwrite toString metho
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265732#comment-17265732
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:20 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265732#comment-17265732
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:19 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265732#comment-17265732
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265732#comment-17265732
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265732#comment-17265732
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:18 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265732#comment-17265732
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:17 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265732#comment-17265732
]
huajiewang edited comment on FLINK-20972 at 1/15/21, 6:16 AM:
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17265732#comment-17265732
]
huajiewang commented on FLINK-20972:
u are right, my Transaction class is here:
sca
[
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
output(l
[
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
output(l
[
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
>
[
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
>
[
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
output(l
[
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 n
[
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 n
[
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 n
[
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 n
[
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 n
[
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 n
[
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 n
[
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 n
[
https://issues.apache.org/jira/browse/FLINK-20972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17264793#comment-17264793
]
huajiewang commented on FLINK-20972:
yes!
> TwoPhaseCommitSinkFunction Output a lar
[
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 n
[
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 n
[
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 EventDat
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
Is
33 matches
Mail list logo