diff --git a/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/log/OperationLog.scala b/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/log/OperationLog.scala index 9ee5e8a1878..b3bd46d35a4 100644 --- a/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/log/OperationLog.scala +++ b/kyuubi-common/src/main/scala/org/apache/kyuubi/operation/log/OperationLog.scala @@ -232,8 +232,6 @@ class OperationLog(path: Path) { } def close(): Unit = synchronized { - if (!initialized) return - closeExtraReaders() trySafely {