From 753b0f1acc6994694d0c6cace0499b05ef352c0d Mon Sep 17 00:00:00 2001 From: Yang Jiandan Date: Sat, 29 Jul 2023 19:28:11 +0800 Subject: [PATCH] fix(gms): GMS hang when upgrade image #8270 (#8271) Co-authored-by: yangjd33 Co-authored-by: david-leifker <114954101+david-leifker@users.noreply.github.com> --- .../metadata/boot/kafka/DataHubUpgradeKafkaListener.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/metadata-service/factories/src/main/java/com/linkedin/metadata/boot/kafka/DataHubUpgradeKafkaListener.java b/metadata-service/factories/src/main/java/com/linkedin/metadata/boot/kafka/DataHubUpgradeKafkaListener.java index e3f3a9c5b76a5..11d12072e12b7 100644 --- a/metadata-service/factories/src/main/java/com/linkedin/metadata/boot/kafka/DataHubUpgradeKafkaListener.java +++ b/metadata-service/factories/src/main/java/com/linkedin/metadata/boot/kafka/DataHubUpgradeKafkaListener.java @@ -108,6 +108,10 @@ public void checkSystemVersion(final ConsumerRecord consu } public void waitForUpdate() { + if (!_configurationProvider.getSystemUpdate().isWaitForSystemUpdate()) { + log.warn("Wait for system update is disabled. Proceeding with startup."); + IS_UPDATED.getAndSet(true); + } int maxBackOffs = Integer.parseInt(_configurationProvider.getSystemUpdate().getMaxBackOffs()); long initialBackOffMs = Long.parseLong(_configurationProvider.getSystemUpdate().getInitialBackOffMs()); int backOffFactor = Integer.parseInt(_configurationProvider.getSystemUpdate().getBackOffFactor());