[jira] [Commented] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847701#comment-17847701 ] Suxing Lee commented on FLINK-35396: Thanks for your reply.  > DynamoDB Streams Con

[jira] [Closed] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suxing Lee closed FLINK-35396. -- Resolution: Duplicate > DynamoDB Streams Consumer consumption data is out of order > -

[jira] [Commented] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847688#comment-17847688 ] Suxing Lee commented on FLINK-35396: [~chalixar] Thanks for your reply. `dynamodb-st

[jira] [Comment Edited] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17847688#comment-17847688 ] Suxing Lee edited comment on FLINK-35396 at 5/19/24 2:48 PM: -

[jira] [Updated] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suxing Lee updated FLINK-35396: --- Affects Version/s: 1.16.2 > DynamoDB Streams Consumer consumption data is out of order > ---

[jira] [Updated] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suxing Lee updated FLINK-35396: --- Affects Version/s: aws-connector-4.2.0 > DynamoDB Streams Consumer consumption data is out of order

[jira] [Updated] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suxing Lee updated FLINK-35396: --- Affects Version/s: (was: 1.16.2) > DynamoDB Streams Consumer consumption data is out of order >

[jira] [Created] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

Suxing Lee created FLINK-35396: -- Summary: DynamoDB Streams Consumer consumption data is out of order Key: FLINK-35396 URL: https://issues.apache.org/jira/browse/FLINK-35396 Project: Flink Issue

[jira] [Created] (FLINK-28353) Exclude unschedulable nodes using IP addresses of kubernetes nodes

Suxing Lee created FLINK-28353: -- Summary: Exclude unschedulable nodes using IP addresses of kubernetes nodes Key: FLINK-28353 URL: https://issues.apache.org/jira/browse/FLINK-28353 Project: Flink

[jira] [Closed] (FLINK-21425) Incorrect implicit conversions in equals and notEquals filter predicates lead to not correctly evaluated by Table API

[ https://issues.apache.org/jira/browse/FLINK-21425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suxing Lee closed FLINK-21425. -- Resolution: Later > Incorrect implicit conversions in equals and notEquals filter predicates lead > t

[jira] [Created] (FLINK-21425) Incorrect implicit conversions in equals and notEquals filter predicates lead to not correctly evaluated by Table API

Suxing Lee created FLINK-21425: -- Summary: Incorrect implicit conversions in equals and notEquals filter predicates lead to not correctly evaluated by Table API Key: FLINK-21425 URL: https://issues.apache.org/jira/bro

[jira] [Commented] (FLINK-11046) ElasticSearch6Connector cause thread blocked when index failed with retry

[ https://issues.apache.org/jira/browse/FLINK-11046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16945072#comment-16945072 ] Suxing Lee commented on FLINK-11046: Another situation that can lead to deadlock is

[jira] [Created] (FLINK-12770) Make number of bulk concurrentRequests configurable

Suxing Lee created FLINK-12770: -- Summary: Make number of bulk concurrentRequests configurable Key: FLINK-12770 URL: https://issues.apache.org/jira/browse/FLINK-12770 Project: Flink Issue Type: I

[jira] [Closed] (FLINK-10447) Create Bucketing Table Sink.

[ https://issues.apache.org/jira/browse/FLINK-10447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suxing Lee closed FLINK-10447. -- Resolution: Duplicate > Create Bucketing Table Sink. > > >

[jira] [Issue Comment Deleted] (FLINK-10447) Create Bucketing Table Sink.

[ https://issues.apache.org/jira/browse/FLINK-10447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suxing Lee updated FLINK-10447: --- Comment: was deleted (was: [~fhueske]  thanks for your comment.   I think StreamingFileSink is very

[jira] [Created] (FLINK-11887) Operator's Latency Metrics continues to increase

Suxing Lee created FLINK-11887: -- Summary: Operator's Latency Metrics continues to increase Key: FLINK-11887 URL: https://issues.apache.org/jira/browse/FLINK-11887 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-10447) Create Bucketing Table Sink.

[ https://issues.apache.org/jira/browse/FLINK-10447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16630179#comment-16630179 ] Suxing Lee commented on FLINK-10447: [~fhueske]  thanks for your comment.   I think

[jira] [Created] (FLINK-10447) Create Bucketing Table Sink.

Suxing Lee created FLINK-10447: -- Summary: Create Bucketing Table Sink. Key: FLINK-10447 URL: https://issues.apache.org/jira/browse/FLINK-10447 Project: Flink Issue Type: New Feature Co