[jira] [Comment Edited] (KAFKA-5756) Synchronization issue on flush

["Chris Egerton (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-5756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17689450#comment-17689450 ] 

Chris Egerton edited comment on KAFKA-5756 at 2/16/23 2:30 AM:
---------------------------------------------------------------

I've merged Greg's fix and updated the fix version to 3.5.0, since this issue was not fully addressed before that fix.

 

I'll backport to 3.3 and 3.4 sometime in the next day or so.


was (Author: chrisegerton):
I've merged Greg's fix and updated the fix version to 3.5.0, since this issue was not fully addressed before that fix.

> Synchronization issue on flush
> ------------------------------
>
>                 Key: KAFKA-5756
>                 URL: https://issues.apache.org/jira/browse/KAFKA-5756
>             Project: Kafka
>          Issue Type: Bug
>          Components: KafkaConnect
>    Affects Versions: 0.10.2.0
>            Reporter: Oleg Kuznetsov
>            Assignee: Greg Harris
>            Priority: Major
>             Fix For: 3.5.0
>
>
> Access to *OffsetStorageWriter#toFlush* is not synchronized in *doFlush()* method, whereas this collection can be accessed from 2 different threads:
> - *WorkerSourceTask.execute()*, finally block
> - *SourceTaskOffsetCommitter*, from periodic flush task



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