[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848851#comment-17848851
]
Vadim Vararu commented on FLINK-35115:
--
Hi guys,
Any idea when the aws-connector-4.3.0 is going
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838934#comment-17838934
]
Danny Cranmer commented on FLINK-35115:
---
Merged commit
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838894#comment-17838894
]
Vadim Vararu commented on FLINK-35115:
--
Great, thanks for quick fix (y)
> Kinesis connector writes
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838884#comment-17838884
]
Danny Cranmer commented on FLINK-35115:
---
[~vadim.vararu] yes it will. 4.3.0 will support Flink
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838854#comment-17838854
]
Vadim Vararu commented on FLINK-35115:
--
[~a.pilipenko] 4.3.0 will be released for Flink 1.18 as
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838853#comment-17838853
]
Vadim Vararu commented on FLINK-35115:
--
[~a.pilipenko] 4.3.0 will be released for Flink 1.18 as
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838358#comment-17838358
]
Aleksandr Pilipenko commented on FLINK-35115:
-
snapshotState method in FlinkKinesisConsumer
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838216#comment-17838216
]
Aleksandr Pilipenko commented on FLINK-35115:
-
Investigating further
> Kinesis connector
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838206#comment-17838206
]
Aleksandr Pilipenko commented on FLINK-35115:
-
[~vadim.vararu] thank you for information.
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838121#comment-17838121
]
Vadim Vararu commented on FLINK-35115:
--
[~a.pilipenko] Yes, I can reproduce this consistently.
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837562#comment-17837562
]
Aleksandr Pilipenko commented on FLINK-35115:
-
[~vadim.vararu] are you able to reproduce
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837533#comment-17837533
]
Vadim Vararu commented on FLINK-35115:
--
FYI it's reproducible in Kinesis -> Flink -> S3 sink also.
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837327#comment-17837327
]
Aleksandr Pilipenko commented on FLINK-35115:
-
[~dannycranmer] Agree, trying to reproduce it
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837319#comment-17837319
]
Hong Liang Teoh commented on FLINK-35115:
-
[~dannycranmer] That is true, unless it is a problem
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837318#comment-17837318
]
Danny Cranmer commented on FLINK-35115:
---
Stop with savepoint checkpointing logic is no different
[
https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17837315#comment-17837315
]
Hong Liang Teoh commented on FLINK-35115:
-
[~a.pilipenko] Assigned to you, as you mentioned you
16 matches
Mail list logo