[jira] [Created] (FLINK-34347) Kubernetes native resource manager request wrong spec.

2024-02-03 Thread Ruibin Xing (Jira)
Ruibin Xing created FLINK-34347: --- Summary: Kubernetes native resource manager request wrong spec. Key: FLINK-34347 URL: https://issues.apache.org/jira/browse/FLINK-34347 Project: Flink Issue

[jira] [Commented] (FLINK-33863) Compressed Operator state restore failed

2023-12-28 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17801086#comment-17801086 ] Ruibin Xing commented on FLINK-33863: - [~martijnvisser] I think so. I have created a backport PR for

[jira] [Commented] (FLINK-33863) Compressed Operator state restore failed

2023-12-19 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17798808#comment-17798808 ] Ruibin Xing commented on FLINK-33863: - [~Yanfei Lei] Hi, I will try to illustrate this problem with

[jira] [Updated] (FLINK-33863) Compressed Operator state restore failed

2023-12-16 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruibin Xing updated FLINK-33863: Description: We encountered an issue when using Flink 1.18.0. Our job enabled Snapshot

[jira] [Created] (FLINK-33863) Compressed Operator state restore failed

2023-12-15 Thread Ruibin Xing (Jira)
Ruibin Xing created FLINK-33863: --- Summary: Compressed Operator state restore failed Key: FLINK-33863 URL: https://issues.apache.org/jira/browse/FLINK-33863 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-33011) Operator deletes HA data unexpectedly

2023-08-31 Thread Ruibin Xing (Jira)
Ruibin Xing created FLINK-33011: --- Summary: Operator deletes HA data unexpectedly Key: FLINK-33011 URL: https://issues.apache.org/jira/browse/FLINK-33011 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-32520) FlinkDeployment recovered states from an obsolete savepoint when performing an upgrade

2023-07-04 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruibin Xing closed FLINK-32520. --- Resolution: Cannot Reproduce > FlinkDeployment recovered states from an obsolete savepoint when

[jira] [Commented] (FLINK-32520) FlinkDeployment recovered states from an obsolete savepoint when performing an upgrade

2023-07-04 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17740009#comment-17740009 ] Ruibin Xing commented on FLINK-32520: - [~gyfora] Sorry, after reviewing, it turns out that the

[jira] [Commented] (FLINK-32520) FlinkDeployment recovered states from an obsolete savepoint when performing an upgrade

2023-07-04 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17739872#comment-17739872 ] Ruibin Xing commented on FLINK-32520: - [~gyfora]  I haven't been able to reproduce this yet.

[jira] [Updated] (FLINK-32520) FlinkDeployment recovered states from an obsolete savepoint when performing an upgrade

2023-07-04 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruibin Xing updated FLINK-32520: Attachment: logs-06151328-06151332.csv > FlinkDeployment recovered states from an obsolete

[jira] [Updated] (FLINK-32520) FlinkDeployment recovered states from an obsolete savepoint when performing an upgrade

2023-07-03 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruibin Xing updated FLINK-32520: Issue Type: Bug (was: New Feature) > FlinkDeployment recovered states from an obsolete savepoint

[jira] [Updated] (FLINK-32520) FlinkDeployment recovered states from an obsolete savepoint when performing an upgrade

2023-07-03 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruibin Xing updated FLINK-32520: Summary: FlinkDeployment recovered states from an obsolete savepoint when performing an upgrade

[jira] [Updated] (FLINK-32520) FlinkDeployment recovered states from an obsolete savepoint

2023-07-03 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruibin Xing updated FLINK-32520: Description: Kubernetes Operator version: 1.5.0   When upgrading one of our Flink jobs, it

[jira] [Created] (FLINK-32520) FlinkDeployment recovered states from an obsolete savepoint

2023-07-03 Thread Ruibin Xing (Jira)
Ruibin Xing created FLINK-32520: --- Summary: FlinkDeployment recovered states from an obsolete savepoint Key: FLINK-32520 URL: https://issues.apache.org/jira/browse/FLINK-32520 Project: Flink

[jira] [Commented] (FLINK-31801) Missing elasticsearch connector on maven central repository

2023-04-14 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712208#comment-17712208 ] Ruibin Xing commented on FLINK-31801: - [~Weijie Guo] Thanks, I will look into it! > Missing

[jira] [Commented] (FLINK-31801) Missing elasticsearch connector on maven central repository

2023-04-14 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17712200#comment-17712200 ] Ruibin Xing commented on FLINK-31801: - Hi [~Weijie Guo], to clarify, does that mean if our project

[jira] [Commented] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector

2023-03-21 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703451#comment-17703451 ] Ruibin Xing commented on FLINK-31483: - [~ruanhang1993] Thanks! I will look into it. > Implement

[jira] [Commented] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector

2023-03-16 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17701017#comment-17701017 ] Ruibin Xing commented on FLINK-31483: - [~ruanhang1993] Thanks for the clarification. I can work on

[jira] [Updated] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector

2023-03-16 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ruibin Xing updated FLINK-31483: Description: Currently, the Flink Kafka Connector does not support split deletion and is left as

[jira] [Commented] (FLINK-30490) Deleted topic from KafkaSource is still included in subsequent restart from savepoint

2023-03-16 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700992#comment-17700992 ] Ruibin Xing commented on FLINK-30490: - [~hilmialf] I created a new ticket for the proposal.

[jira] [Created] (FLINK-31483) Implement Split Deletion Support in Flink Kafka Connector

2023-03-16 Thread Ruibin Xing (Jira)
Ruibin Xing created FLINK-31483: --- Summary: Implement Split Deletion Support in Flink Kafka Connector Key: FLINK-31483 URL: https://issues.apache.org/jira/browse/FLINK-31483 Project: Flink

[jira] [Comment Edited] (FLINK-30490) Deleted topic from KafkaSource is still included in subsequent restart from savepoint

2023-03-15 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700942#comment-17700942 ] Ruibin Xing edited comment on FLINK-30490 at 3/16/23 3:05 AM: -- hi, we are

[jira] [Commented] (FLINK-30490) Deleted topic from KafkaSource is still included in subsequent restart from savepoint

2023-03-15 Thread Ruibin Xing (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17700942#comment-17700942 ] Ruibin Xing commented on FLINK-30490: - hi, we are encountering the same issue and are actively