[jira] [Commented] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService

2024-05-22 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848646#comment-17848646 ] Hong Liang Teoh commented on FLINK-34672: - [~mapohl] do we know if this should be a blocker to

[jira] [Comment Edited] (FLINK-34672) HA deadlock between JobMasterServiceLeadershipRunner and DefaultLeaderElectionService

2024-05-22 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848646#comment-17848646 ] Hong Liang Teoh edited comment on FLINK-34672 at 5/22/24 2:29 PM: --

[jira] [Commented] (FLINK-34379) table.optimizer.dynamic-filtering.enabled lead to OutOfMemoryError

2024-05-22 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848644#comment-17848644 ] Hong Liang Teoh commented on FLINK-34379: - [~jeyhunkarimov] Any progress on this patch? >

[jira] [Resolved] (FLINK-35383) Update compatibility matrix to include 1.19 release

2024-05-21 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-35383. - Resolution: Fixed > Update compatibility matrix to include 1.19 release >

[jira] [Commented] (FLINK-35383) Update compatibility matrix to include 1.19 release

2024-05-21 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848246#comment-17848246 ] Hong Liang Teoh commented on FLINK-35383: - merged commit

[jira] [Commented] (FLINK-35383) Update compatibility matrix to include 1.19 release

2024-05-21 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35383?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17848247#comment-17848247 ] Hong Liang Teoh commented on FLINK-35383: - merged commit

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

2024-05-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847700#comment-17847700 ] Hong Liang Teoh commented on FLINK-35396: - Here is the Parent-Jira that will introduce the new

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

2024-05-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847698#comment-17847698 ] Hong Liang Teoh commented on FLINK-35396: - Hi [~Suxing Lee], thanks for reporting this problem.

[jira] [Resolved] (FLINK-35269) Fix logging level for errors in AWS connector sinks

2024-05-17 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-35269. - Assignee: Aleksandr Pilipenko Resolution: Fixed > Fix logging level for errors in

[jira] [Commented] (FLINK-35269) Fix logging level for errors in AWS connector sinks

2024-05-17 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847213#comment-17847213 ] Hong Liang Teoh commented on FLINK-35269: -  merged commit

[jira] [Updated] (FLINK-35269) Fix logging level for errors in AWS connector sinks

2024-05-17 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-35269: Fix Version/s: aws-connector-4.3.0 > Fix logging level for errors in AWS connector sinks

[jira] [Assigned] (FLINK-35383) Update compatibility matrix to include 1.19 release

2024-05-16 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-35383: --- Assignee: Aleksandr Pilipenko > Update compatibility matrix to include 1.19

[jira] [Updated] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot

2024-05-06 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-35299: Description: h3. What The FlinkKinesisConsumer allows users to read from [multiple

[jira] [Created] (FLINK-35299) FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot

2024-05-06 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-35299: --- Summary: FlinkKinesisConsumer does not respect StreamInitialPosition for new Kinesis Stream when restoring from snapshot Key: FLINK-35299 URL:

[jira] [Commented] (FLINK-35069) ContinuousProcessingTimeTrigger continuously registers timers in a loop at the end of the window

2024-04-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17838962#comment-17838962 ] Hong Liang Teoh commented on FLINK-35069: - Thanks [~lijinzhong] for the fix! Are we planning to

[jira] [Assigned] (FLINK-35134) Release flink-connector-elasticsearch vX.X.X for Flink 1.19

2024-04-17 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-35134: --- Assignee: Hong Liang Teoh > Release flink-connector-elasticsearch vX.X.X for Flink

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

2024-04-15 Thread Hong Liang Teoh (Jira)
[ 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

[jira] [Commented] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

2024-04-15 Thread Hong Liang Teoh (Jira)
[ 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

[jira] [Assigned] (FLINK-35115) Kinesis connector writes wrong Kinesis sequence number at stop with savepoint

2024-04-15 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-35115: --- Assignee: Aleksandr Pilipenko > Kinesis connector writes wrong Kinesis sequence

[jira] [Resolved] (FLINK-34025) Show data skew score on Flink Dashboard

2024-04-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-34025. - Resolution: Done > Show data skew score on Flink Dashboard >

[jira] [Commented] (FLINK-34025) Show data skew score on Flink Dashboard

2024-04-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17834339#comment-17834339 ] Hong Liang Teoh commented on FLINK-34025: -  merged commit

[jira] [Assigned] (FLINK-34025) Show data skew score on Flink Dashboard

2024-04-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-34025: --- Assignee: Emre Kartoglu > Show data skew score on Flink Dashboard >

[jira] [Updated] (FLINK-32964) KinesisStreamsSink cant renew credentials with WebIdentityTokenFileCredentialsProvider

2024-03-06 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32964: Fix Version/s: aws-connector-4.3.0 > KinesisStreamsSink cant renew credentials with >

[jira] [Assigned] (FLINK-32964) KinesisStreamsSink cant renew credentials with WebIdentityTokenFileCredentialsProvider

2024-03-06 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-32964: --- Assignee: Aleksandr Pilipenko > KinesisStreamsSink cant renew credentials with >

[jira] [Resolved] (FLINK-32964) KinesisStreamsSink cant renew credentials with WebIdentityTokenFileCredentialsProvider

2024-03-06 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-32964. - Resolution: Fixed > KinesisStreamsSink cant renew credentials with >

[jira] [Commented] (FLINK-32964) KinesisStreamsSink cant renew credentials with WebIdentityTokenFileCredentialsProvider

2024-02-15 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17817750#comment-17817750 ] Hong Liang Teoh commented on FLINK-32964: -  merged commit

[jira] [Resolved] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces

2024-02-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-34260. - Resolution: Fixed > Update flink-connector-aws to be compatible with updated SinkV2

[jira] [Commented] (FLINK-34260) Update flink-connector-aws to be compatible with updated SinkV2 interfaces

2024-02-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34260?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816317#comment-17816317 ] Hong Liang Teoh commented on FLINK-34260: -  merged commit

[jira] [Commented] (FLINK-34407) Flaky tests causing workflow timeout

2024-02-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816313#comment-17816313 ] Hong Liang Teoh commented on FLINK-34407: - merged commit

[jira] [Resolved] (FLINK-34407) Flaky tests causing workflow timeout

2024-02-10 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-34407. - Resolution: Fixed > Flaky tests causing workflow timeout >

[jira] [Commented] (FLINK-34071) Deadlock in AWS Kinesis Data Streams AsyncSink connector

2024-01-15 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17806733#comment-17806733 ] Hong Liang Teoh commented on FLINK-34071: - As discussed offline, wonder if we can add a timeout

[jira] [Assigned] (FLINK-33995) Add test in test_file_sink.sh s3 StreamingFileSink for csv

2024-01-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33995: --- Assignee: Samrat Deb > Add test in test_file_sink.sh s3 StreamingFileSink for csv

[jira] [Resolved] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33872. - Resolution: Fixed > Checkpoint history does not display for completed jobs >

[jira] [Commented] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798635#comment-17798635 ] Hong Liang Teoh commented on FLINK-33872: - merged commit 

[jira] [Commented] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798634#comment-17798634 ] Hong Liang Teoh commented on FLINK-33872: - merged commit 

[jira] [Assigned] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33872: --- Assignee: Hong Liang Teoh > Checkpoint history does not display for completed jobs

[jira] [Created] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33872: --- Summary: Checkpoint history does not display for completed jobs Key: FLINK-33872 URL: https://issues.apache.org/jira/browse/FLINK-33872 Project: Flink

[jira] [Updated] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33872: Description: Prior to https://issues.apache.org/jira/browse/FLINK-32469, we see

[jira] [Updated] (FLINK-33872) Checkpoint history does not display for completed jobs

2023-12-18 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33872: Description: Prior to https://issues.apache.org/jira/browse/FLINK-32469, we see

[jira] [Commented] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer

2023-11-24 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789436#comment-17789436 ] Hong Liang Teoh commented on FLINK-6349: This will be addressed by the new FLIP-27 based

[jira] [Updated] (FLINK-6349) Enforce per-subtask record ordering on resharding for FlinkKinesisConsumer

2023-11-24 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-6349: --- Priority: Major (was: Not a Priority) > Enforce per-subtask record ordering on resharding

[jira] [Assigned] (FLINK-33194) AWS Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-27 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33194: --- Assignee: Jiabao Sun > AWS Connector should directly depend on 3rd-party libs

[jira] [Resolved] (FLINK-33194) AWS Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-27 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33194. - Resolution: Fixed > AWS Connector should directly depend on 3rd-party libs instead of

[jira] [Commented] (FLINK-33194) AWS Connector should directly depend on 3rd-party libs instead of flink-shaded repo

2023-10-27 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17780273#comment-17780273 ] Hong Liang Teoh commented on FLINK-33194: - merged commit

[jira] [Commented] (FLINK-32399) Fix flink-sql-connector-kinesis build for maven 3.8.6+

2023-10-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774628#comment-17774628 ] Hong Liang Teoh commented on FLINK-32399: - Ah, that's a good call. We will need to make some

[jira] [Created] (FLINK-33259) flink-connector-aws should use/extend the common connector workflow

2023-10-12 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33259: --- Summary: flink-connector-aws should use/extend the common connector workflow Key: FLINK-33259 URL: https://issues.apache.org/jira/browse/FLINK-33259 Project:

[jira] [Assigned] (FLINK-32399) Fix flink-sql-connector-kinesis build for maven 3.8.6+

2023-10-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-32399: --- Assignee: Aleksandr Pilipenko > Fix flink-sql-connector-kinesis build for maven

[jira] [Resolved] (FLINK-32399) Fix flink-sql-connector-kinesis build for maven 3.8.6+

2023-10-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-32399. - Resolution: Fixed > Fix flink-sql-connector-kinesis build for maven 3.8.6+ >

[jira] [Commented] (FLINK-32399) Fix flink-sql-connector-kinesis build for maven 3.8.6+

2023-10-12 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17774539#comment-17774539 ] Hong Liang Teoh commented on FLINK-32399: - merged commit

[jira] [Resolved] (FLINK-33141) Promentheus Sink Connector - Amazon Managed Prometheus Request Signer

2023-10-09 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33141. - Resolution: Implemented Resolved by https://issues.apache.org/jira/browse/FLINK-33138

[jira] [Assigned] (FLINK-33138) Prometheus Connector Sink - DataStream API implementation

2023-10-09 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33138: --- Assignee: Lorenzo Nicora > Prometheus Connector Sink - DataStream API

[jira] [Commented] (FLINK-33175) Nightly builds from S3 are not available for download, breaking all connector tests

2023-10-09 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17773294#comment-17773294 ] Hong Liang Teoh commented on FLINK-33175: - Verified the flink-connector-aws one succeeds as

[jira] [Created] (FLINK-33167) Run IT tests against Kinesalite if AWS credentials are not present

2023-09-28 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33167: --- Summary: Run IT tests against Kinesalite if AWS credentials are not present Key: FLINK-33167 URL: https://issues.apache.org/jira/browse/FLINK-33167 Project:

[jira] [Assigned] (FLINK-33137) FLIP-312: Prometheus Sink Connector

2023-09-25 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33137: --- Assignee: Lorenzo Nicora > FLIP-312: Prometheus Sink Connector >

[jira] [Resolved] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-32962. - Resolution: Fixed > Failure to install python dependencies from requirements file >

[jira] [Commented] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17766736#comment-17766736 ] Hong Liang Teoh commented on FLINK-32962: - merged commit 

[jira] [Assigned] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

2023-09-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33073?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33073: --- Assignee: Hong Liang Teoh > Implement end-to-end tests for the Kinesis Streams

[jira] [Updated] (FLINK-33072) Implement end-to-end tests for AWS Kinesis Connectors

2023-09-11 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33072: Description: *What* We want to implement end-to-end tests that target real Kinesis Data

[jira] [Created] (FLINK-33073) Implement end-to-end tests for the Kinesis Streams Sink

2023-09-11 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33073: --- Summary: Implement end-to-end tests for the Kinesis Streams Sink Key: FLINK-33073 URL: https://issues.apache.org/jira/browse/FLINK-33073 Project: Flink

[jira] [Created] (FLINK-33072) Implement end-to-end tests for AWS Kinesis Connectors

2023-09-11 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-33072: --- Summary: Implement end-to-end tests for AWS Kinesis Connectors Key: FLINK-33072 URL: https://issues.apache.org/jira/browse/FLINK-33072 Project: Flink

[jira] [Updated] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-08 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32962: Fix Version/s: 1.17.2 > Failure to install python dependencies from requirements file >

[jira] [Commented] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-08 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17763052#comment-17763052 ] Hong Liang Teoh commented on FLINK-32962: - merged commit 

[jira] [Updated] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-08 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32962: Fix Version/s: 1.18.0 1.19.0 > Failure to install python dependencies

[jira] [Commented] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-07 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762807#comment-17762807 ] Hong Liang Teoh commented on FLINK-32962: - [~a.pilipenko]  should we also backport this to Flink

[jira] [Commented] (FLINK-32962) Failure to install python dependencies from requirements file

2023-09-07 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762805#comment-17762805 ] Hong Liang Teoh commented on FLINK-32962: - merged commit

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762042#comment-17762042 ] Hong Liang Teoh commented on FLINK-33021: - merged commit 

[jira] [Resolved] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-33021. - Resolution: Fixed > AWS nightly builds fails on architecture tests >

[jira] [Assigned] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-33021: --- Assignee: Hong Liang Teoh > AWS nightly builds fails on architecture tests >

[jira] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021 ] Hong Liang Teoh deleted comment on FLINK-33021: - was (Author: hong): Triggering the nightly build now.  https://github.com/apache/flink-connector-aws/actions/runs/6067488560 > AWS

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762040#comment-17762040 ] Hong Liang Teoh commented on FLINK-33021: - Latest nightly build has passed. Will resolve this

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17762039#comment-17762039 ] Hong Liang Teoh commented on FLINK-28513: - merged commit 

[jira] [Updated] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-33021: Fix Version/s: aws-connector-4.2.0 > AWS nightly builds fails on architecture tests >

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761861#comment-17761861 ] Hong Liang Teoh commented on FLINK-33021: - Triggering the nightly build now. 

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761860#comment-17761860 ] Hong Liang Teoh commented on FLINK-33021: - Ah. I only saw this now :( But I'll link the PR for

[jira] [Comment Edited] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761856#comment-17761856 ] Hong Liang Teoh edited comment on FLINK-28513 at 9/4/23 3:17 PM: -

[jira] [Updated] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-28513: Fix Version/s: 1.18.0 1.17.2 > Flink Table API CSV streaming sink

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761856#comment-17761856 ] Hong Liang Teoh commented on FLINK-28513: - > I dont have access to update the fix version .

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761855#comment-17761855 ] Hong Liang Teoh commented on FLINK-28513: - merged commit 

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761787#comment-17761787 ] Hong Liang Teoh commented on FLINK-28513: - [~samrat007]  Could we backport this bugfix to Flink

[jira] [Resolved] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-28513. - Fix Version/s: 1.19.0 Resolution: Fixed > Flink Table API CSV streaming sink

[jira] [Commented] (FLINK-28513) Flink Table API CSV streaming sink throws SerializedThrowable exception

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761785#comment-17761785 ] Hong Liang Teoh commented on FLINK-28513: -  merged commit 

[jira] [Comment Edited] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761740#comment-17761740 ] Hong Liang Teoh edited comment on FLINK-33021 at 9/4/23 9:01 AM: - This

[jira] [Commented] (FLINK-33021) AWS nightly builds fails on architecture tests

2023-09-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33021?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17761740#comment-17761740 ] Hong Liang Teoh commented on FLINK-33021: - This has been fixed here!  > AWS nightly builds

[jira] [Assigned] (FLINK-32757) Update the copyright year in NOTICE files

2023-08-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh reassigned FLINK-32757: --- Assignee: Jiabao Sun > Update the copyright year in NOTICE files >

[jira] [Resolved] (FLINK-32757) Update the copyright year in NOTICE files

2023-08-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-32757. - Resolution: Fixed > Update the copyright year in NOTICE files >

[jira] [Commented] (FLINK-32757) Update the copyright year in NOTICE files

2023-08-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32757?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751227#comment-17751227 ] Hong Liang Teoh commented on FLINK-32757: - Merged commit

[jira] [Created] (FLINK-32703) [hotfix] flink-python POM has a typo for protobuf-java in shading config

2023-07-27 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-32703: --- Summary: [hotfix] flink-python POM has a typo for protobuf-java in shading config Key: FLINK-32703 URL: https://issues.apache.org/jira/browse/FLINK-32703

[jira] [Commented] (FLINK-32619) ConfigOptions to support fallback configuration

2023-07-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17744606#comment-17744606 ] Hong Liang Teoh commented on FLINK-32619: - That's a great callout [~wangm92] . Will use that

[jira] [Resolved] (FLINK-32619) ConfigOptions to support fallback configuration

2023-07-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh resolved FLINK-32619. - Resolution: Not A Problem > ConfigOptions to support fallback configuration >

[jira] [Created] (FLINK-32619) ConfigOptions to support fallback configuration

2023-07-18 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-32619: --- Summary: ConfigOptions to support fallback configuration Key: FLINK-32619 URL: https://issues.apache.org/jira/browse/FLINK-32619 Project: Flink Issue

[jira] [Commented] (FLINK-32508) Flink-Metrics Prometheus - Native Histograms / Native Counters

2023-07-07 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740995#comment-17740995 ] Hong Liang Teoh commented on FLINK-32508: - [~martijnvisser]  Sounds great! Always happy to

[jira] [Commented] (FLINK-32508) Flink-Metrics Prometheus - Native Histograms / Native Counters

2023-07-07 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740939#comment-17740939 ] Hong Liang Teoh commented on FLINK-32508: - Happy to take a look at this, can I please be

[jira] [Comment Edited] (FLINK-32537) Add compatibility annotation for REST API classes

2023-07-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740266#comment-17740266 ] Hong Liang Teoh edited comment on FLINK-32537 at 7/5/23 3:42 PM: - > We

[jira] [Commented] (FLINK-32537) Add compatibility annotation for REST API classes

2023-07-05 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740266#comment-17740266 ] Hong Liang Teoh commented on FLINK-32537: - > We already know that though due to the

[jira] [Created] (FLINK-32537) Add compatibility annotation for REST API classes

2023-07-04 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-32537: --- Summary: Add compatibility annotation for REST API classes Key: FLINK-32537 URL: https://issues.apache.org/jira/browse/FLINK-32537 Project: Flink

[jira] [Updated] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts

2023-07-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32535: Description: *What* When making requests to /checkpoints REST API after a job restart,

[jira] [Created] (FLINK-32535) CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts

2023-07-04 Thread Hong Liang Teoh (Jira)
Hong Liang Teoh created FLINK-32535: --- Summary: CheckpointingStatisticsHandler periodically returns NullArgumentException after job restarts Key: FLINK-32535 URL:

[jira] [Commented] (FLINK-32469) Improve checkpoint REST APIs for programmatic access

2023-07-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739912#comment-17739912 ] Hong Liang Teoh commented on FLINK-32469: - Thanks for the review [~dmvk] , Rephrased the

[jira] [Updated] (FLINK-32469) Improve checkpoint REST APIs for programmatic access

2023-07-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32469: Description: *Why* We want to enable programmatic use of the checkpoints REST API,

[jira] [Updated] (FLINK-32469) Improve checkpoint REST APIs for programmatic access

2023-07-04 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hong Liang Teoh updated FLINK-32469: Description: *Why* We want to enable programmatic use of the checkpoints REST API,

  1   2   3   >