[
https://issues.apache.org/jira/browse/KAFKA-6869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Oleg Kuznetsov updated KAFKA-6869:
----------------------------------
Description:
{code:java}
org.apache.kafka.connect.runtime.distributed.DistributedHerder#needsReconfigRebalance{code}
field is read/written with and without *synchronized* in multiple places, that
is incorrect by JMM.
I propose to either add *synchronized* to access it in all places or use RW
lock varying type of locking for reading and writing.
was:
{code}org.apache.kafka.connect.runtime.distributed.DistributedHerder#needsReconfigRebalance{code}
field is read/write with and without *synchronized* in multiple places, that
is incorrect by JMM.
I propose to either adding synchronized to access it in all places or using RW
lock varying type of locking for reading and writing.
> Distributed herder synchronization issue
> ----------------------------------------
>
> Key: KAFKA-6869
> URL: https://issues.apache.org/jira/browse/KAFKA-6869
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 1.1.0
> Reporter: Oleg Kuznetsov
> Priority: Major
>
> {code:java}
> org.apache.kafka.connect.runtime.distributed.DistributedHerder#needsReconfigRebalance{code}
> field is read/written with and without *synchronized* in multiple places,
> that is incorrect by JMM.
> I propose to either add *synchronized* to access it in all places or use RW
> lock varying type of locking for reading and writing.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
