MINOR: fix a small typo in SharedServer.scala (#13693)

Diabled -> Disabled
apache · May 11, 2023 · 920a360 · 920a360
1 parent 6d2ad4a
commit 920a360
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/core/src/main/scala/kafka/server/SharedServer.scala b/core/src/main/scala/kafka/server/SharedServer.scala
@@ -103,7 +103,7 @@ class SharedServer(
   @volatile var brokerMetrics: BrokerServerMetrics = _
   @volatile var controllerServerMetrics: ControllerMetadataMetrics = _
   @volatile var loader: MetadataLoader = _
-  val snapshotsDiabledReason = new AtomicReference[String](null)
+  val snapshotsDisabledReason = new AtomicReference[String](null)
   @volatile var snapshotEmitter: SnapshotEmitter = _
   @volatile var snapshotGenerator: SnapshotGenerator = _
 
@@ -166,7 +166,7 @@ class SharedServer(
     action = () => SharedServer.this.synchronized {
       Option(brokerMetrics).foreach(_.metadataLoadErrorCount.getAndIncrement())
       Option(controllerServerMetrics).foreach(_.incrementMetadataErrorCount())
-      snapshotsDiabledReason.compareAndSet(null, "metadata loading fault")
+      snapshotsDisabledReason.compareAndSet(null, "metadata loading fault")
     })
 
   /**
@@ -177,7 +177,7 @@ class SharedServer(
     fatal = true,
     action = () => SharedServer.this.synchronized {
       Option(controllerServerMetrics).foreach(_.incrementMetadataErrorCount())
-      snapshotsDiabledReason.compareAndSet(null, "controller startup fault")
+      snapshotsDisabledReason.compareAndSet(null, "controller startup fault")
     })
 
   /**
@@ -189,7 +189,7 @@ class SharedServer(
     action = () => SharedServer.this.synchronized {
       Option(brokerMetrics).foreach(_.metadataApplyErrorCount.getAndIncrement())
       Option(controllerServerMetrics).foreach(_.incrementMetadataErrorCount())
-      snapshotsDiabledReason.compareAndSet(null, "initial broker metadata loading fault")
+      snapshotsDisabledReason.compareAndSet(null, "initial broker metadata loading fault")
     })
 
   /**
@@ -200,7 +200,7 @@ class SharedServer(
     fatal = true,
     action = () => SharedServer.this.synchronized {
       Option(controllerServerMetrics).foreach(_.incrementMetadataErrorCount())
-      snapshotsDiabledReason.compareAndSet(null, "quorum controller fault")
+      snapshotsDisabledReason.compareAndSet(null, "quorum controller fault")
     })
 
   /**
@@ -269,7 +269,7 @@ class SharedServer(
           setFaultHandler(metadataPublishingFaultHandler).
           setMaxBytesSinceLastSnapshot(sharedServerConfig.metadataSnapshotMaxNewRecordBytes).
           setMaxTimeSinceLastSnapshotNs(TimeUnit.MILLISECONDS.toNanos(sharedServerConfig.metadataSnapshotMaxIntervalMs)).
-          setDisabledReason(snapshotsDiabledReason).
+          setDisabledReason(snapshotsDisabledReason).
           setThreadNamePrefix(s"kafka-${sharedServerConfig.nodeId}-").
           build()
         _raftManager.register(loader)