[jira] [Comment Edited] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-05-10 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842254#comment-17842254 ] Flaviu Cicio edited comment on FLINK-33989 at 5/10/24 7:30 AM: ---

[jira] [Comment Edited] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-04-29 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842254#comment-17842254 ] Flaviu Cicio edited comment on FLINK-33989 at 4/30/24 6:30 AM: ---

[jira] [Commented] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-04-29 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17842254#comment-17842254 ] Flaviu Cicio commented on FLINK-33989: -- Thank you all for your involvement!   >From

[jira] [Commented] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-02-20 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818860#comment-17818860 ] Flaviu Cicio commented on FLINK-33989: -- Hi, [~xuyangzhong]!  Here is the output of

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Description: Given the following Flink SQL tables: {code:sql} CREATE TABLE input (   id STRING N

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Description: Given the following Flink SQL tables: {code:sql} CREATE TABLE input (   id STRING N

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Description: Given the following Flink SQL tables: {code:sql} CREATE TABLE input (   id STRING N

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Description: Given the following Flink SQL tables: {code:sql} CREATE TABLE input (   id STRING N

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Description: Given the following Flink SQL tables: {code:sql} CREATE TABLE input (   id STRING N

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Description: Given the following Flink SQL tables: {code:sql} CREATE TABLE input (   id STRING N

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Description: Given the following Flink SQL tables: {code:sql} CREATE TABLE input (   id STRING N

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Description: Given the following Flink SQL tables: {code:sql} CREATE TABLE input (   id STRING N

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Component/s: Connectors / Kafka > Insert Statement With Filter Operation Generates Extra Tombsto

[jira] [Updated] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Connector

2024-01-04 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33989?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flaviu Cicio updated FLINK-33989: - Summary: Insert Statement With Filter Operation Generates Extra Tombstone using Upsert Kafka Con

[jira] [Created] (FLINK-33989) Insert Statement With Filter Operation Generates Extra Tombstone in Kafka

2024-01-04 Thread Flaviu Cicio (Jira)
Flaviu Cicio created FLINK-33989: Summary: Insert Statement With Filter Operation Generates Extra Tombstone in Kafka Key: FLINK-33989 URL: https://issues.apache.org/jira/browse/FLINK-33989 Project: Fl

[jira] [Commented] (FLINK-30831) Improving e2e test output in case errors/exceptions are found

2023-09-23 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768256#comment-17768256 ] Flaviu Cicio commented on FLINK-30831: -- [~mapohl] Can I take this ticket as my firs

[jira] [Comment Edited] (FLINK-30831) Improving e2e test output in case errors/exceptions are found

2023-09-23 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30831?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17768256#comment-17768256 ] Flaviu Cicio edited comment on FLINK-30831 at 9/23/23 9:55 AM: ---

[jira] [Commented] (FLINK-30649) Shutting down MiniCluster times out

2023-09-21 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767581#comment-17767581 ] Flaviu Cicio commented on FLINK-30649: -- The issue is not reproducing anymore, thus

[jira] [Commented] (FLINK-30649) Shutting down MiniCluster times out

2023-09-20 Thread Flaviu Cicio (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767154#comment-17767154 ] Flaviu Cicio commented on FLINK-30649: -- Hi, [~mapohl] Can I have this one as my fi