[jira] [Updated] (CASSANALYTICS-126) Missing flushing pending events before CDC persisting state

2026-03-23 Thread Jyothsna Konisa (Jira)


 [ 
https://issues.apache.org/jira/browse/CASSANALYTICS-126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jyothsna Konisa updated CASSANALYTICS-126:
--
Source Control Link: 
https://github.com/apache/cassandra-analytics/commit/ba38f156375a51c9e6639ce92c3da88b627e4ac4
 Resolution: Fixed
 Status: Resolved  (was: Ready to Commit)

> Missing flushing pending events before CDC persisting state
> ---
>
> Key: CASSANALYTICS-126
> URL: https://issues.apache.org/jira/browse/CASSANALYTICS-126
> Project: Apache Cassandra Analytics
>  Issue Type: Bug
>  Components: CDC
>Reporter: Jyothsna Konisa
>Assignee: Jyothsna Konisa
>Priority: Normal
> Fix For: 0.4
>
>  Time Spent: 1h 40m
>  Remaining Estimate: 0h
>
> After each micro batch in CDC produces mutations, flush has to be called to 
> ensure all produced events are delivered before we commit the state. 
> If this is not done, there is a chance of loosing mutations during restarts 
> and Kafka going down scenarios.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]



[jira] [Updated] (CASSANALYTICS-126) Missing flushing pending events before CDC persisting state

2026-03-16 Thread Josh McKenzie (Jira)


 [ 
https://issues.apache.org/jira/browse/CASSANALYTICS-126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Josh McKenzie updated CASSANALYTICS-126:

Status: Ready to Commit  (was: Review In Progress)

> Missing flushing pending events before CDC persisting state
> ---
>
> Key: CASSANALYTICS-126
> URL: https://issues.apache.org/jira/browse/CASSANALYTICS-126
> Project: Apache Cassandra Analytics
>  Issue Type: Bug
>  Components: CDC
>Reporter: Jyothsna Konisa
>Assignee: Jyothsna Konisa
>Priority: Normal
> Fix For: 0.4
>
>  Time Spent: 1.5h
>  Remaining Estimate: 0h
>
> After each micro batch in CDC produces mutations, flush has to be called to 
> ensure all produced events are delivered before we commit the state. 
> If this is not done, there is a chance of loosing mutations during restarts 
> and Kafka going down scenarios.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]



[jira] [Updated] (CASSANALYTICS-126) Missing flushing pending events before CDC persisting state

2026-03-16 Thread Josh McKenzie (Jira)


 [ 
https://issues.apache.org/jira/browse/CASSANALYTICS-126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Josh McKenzie updated CASSANALYTICS-126:

Reviewers: Josh McKenzie, Josh McKenzie  (was: Josh McKenzie)
   Josh McKenzie, Josh McKenzie  (was: Josh McKenzie)
   Status: Review In Progress  (was: Patch Available)

> Missing flushing pending events before CDC persisting state
> ---
>
> Key: CASSANALYTICS-126
> URL: https://issues.apache.org/jira/browse/CASSANALYTICS-126
> Project: Apache Cassandra Analytics
>  Issue Type: Bug
>  Components: CDC
>Reporter: Jyothsna Konisa
>Assignee: Jyothsna Konisa
>Priority: Normal
> Fix For: 0.4
>
>  Time Spent: 1.5h
>  Remaining Estimate: 0h
>
> After each micro batch in CDC produces mutations, flush has to be called to 
> ensure all produced events are delivered before we commit the state. 
> If this is not done, there is a chance of loosing mutations during restarts 
> and Kafka going down scenarios.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]



[jira] [Updated] (CASSANALYTICS-126) Missing flushing pending events before CDC persisting state

2026-03-05 Thread Josh McKenzie (Jira)


 [ 
https://issues.apache.org/jira/browse/CASSANALYTICS-126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Josh McKenzie updated CASSANALYTICS-126:

Reviewers: Josh McKenzie

> Missing flushing pending events before CDC persisting state
> ---
>
> Key: CASSANALYTICS-126
> URL: https://issues.apache.org/jira/browse/CASSANALYTICS-126
> Project: Apache Cassandra Analytics
>  Issue Type: Bug
>  Components: CDC
>Reporter: Jyothsna Konisa
>Assignee: Jyothsna Konisa
>Priority: Normal
> Fix For: 0.4
>
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> After each micro batch in CDC produces mutations, flush has to be called to 
> ensure all produced events are delivered before we commit the state. 
> If this is not done, there is a chance of loosing mutations during restarts 
> and Kafka going down scenarios.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]



[jira] [Updated] (CASSANALYTICS-126) Missing flushing pending events before CDC persisting state

2026-03-05 Thread Jyothsna Konisa (Jira)


 [ 
https://issues.apache.org/jira/browse/CASSANALYTICS-126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jyothsna Konisa updated CASSANALYTICS-126:
--
Authors: Jyothsna Konisa
Test and Documentation Plan: Tested various failure scenarios and validated 
that mutations are being produced for all the writes during sidecar restarts, 
kafka unavailable scenarios
 Status: Patch Available  (was: Open)

> Missing flushing pending events before CDC persisting state
> ---
>
> Key: CASSANALYTICS-126
> URL: https://issues.apache.org/jira/browse/CASSANALYTICS-126
> Project: Apache Cassandra Analytics
>  Issue Type: Bug
>  Components: CDC
>Reporter: Jyothsna Konisa
>Assignee: Jyothsna Konisa
>Priority: Normal
> Fix For: 0.4
>
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> After each micro batch in CDC produces mutations, flush has to be called to 
> ensure all produced events are delivered before we commit the state. 
> If this is not done, there is a chance of loosing mutations during restarts 
> and Kafka going down scenarios.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]



[jira] [Updated] (CASSANALYTICS-126) Missing flushing pending events before CDC persisting state

2026-03-05 Thread Jyothsna Konisa (Jira)


 [ 
https://issues.apache.org/jira/browse/CASSANALYTICS-126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jyothsna Konisa updated CASSANALYTICS-126:
--
 Bug Category: Parent values: Correctness(12982)
   Complexity: Normal
  Component/s: CDC
Discovered By: Adhoc Test
Fix Version/s: 0.4
 Severity: Critical
 Assignee: Jyothsna Konisa
   Status: Open  (was: Triage Needed)

> Missing flushing pending events before CDC persisting state
> ---
>
> Key: CASSANALYTICS-126
> URL: https://issues.apache.org/jira/browse/CASSANALYTICS-126
> Project: Apache Cassandra Analytics
>  Issue Type: Bug
>  Components: CDC
>Reporter: Jyothsna Konisa
>Assignee: Jyothsna Konisa
>Priority: Normal
> Fix For: 0.4
>
>  Time Spent: 10m
>  Remaining Estimate: 0h
>
> After each micro batch in CDC produces mutations, flush has to be called to 
> ensure all produced events are delivered before we commit the state. 
> If this is not done, there is a chance of loosing mutations during restarts 
> and Kafka going down scenarios.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

-
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]