From 87a7cb2d1c491587b2a83bd997642f6052d96ebf Mon Sep 17 00:00:00 2001 From: Renju Radhakrishnan Date: Wed, 23 Jun 2021 15:20:31 -0700 Subject: [PATCH] Remove synchronzed block for preventing shard sync contention --- .../software/amazon/kinesis/leases/HierarchicalShardSyncer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java index 4f677524..369bd347 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java @@ -110,7 +110,7 @@ public class HierarchicalShardSyncer { * @throws KinesisClientLibIOException */ // CHECKSTYLE:OFF CyclomaticComplexity - public synchronized boolean checkAndCreateLeaseForNewShards(@NonNull final ShardDetector shardDetector, + public boolean checkAndCreateLeaseForNewShards(@NonNull final ShardDetector shardDetector, final LeaseRefresher leaseRefresher, final InitialPositionInStreamExtended initialPosition, final MetricsScope scope, final boolean ignoreUnexpectedChildShards, final boolean isLeaseTableEmpty) throws DependencyException, InvalidStateException, ProvisionedThroughputException, KinesisClientLibIOException, InterruptedException {