mirror of https://github.com/apache/kafka.git
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>, Greg Harris <greg.harris@aiven.io>, Chris Egerton <chrise@aiven.io> Co-authored-by: Dmitry Werner <grimekillah@gmail.com>
This commit is contained in:
parent
67151c6022
commit
abaecdf63e
|
|
@ -461,7 +461,6 @@ object StorageTool extends Logging {
|
||||||
metaPropertiesEnsemble.verify(metaProperties.clusterId(), metaProperties.nodeId(),
|
metaPropertiesEnsemble.verify(metaProperties.clusterId(), metaProperties.nodeId(),
|
||||||
util.EnumSet.noneOf(classOf[VerificationFlag]))
|
util.EnumSet.noneOf(classOf[VerificationFlag]))
|
||||||
|
|
||||||
System.out.println(s"metaPropertiesEnsemble=${metaPropertiesEnsemble}")
|
|
||||||
val copier = new MetaPropertiesEnsemble.Copier(metaPropertiesEnsemble)
|
val copier = new MetaPropertiesEnsemble.Copier(metaPropertiesEnsemble)
|
||||||
if (!(ignoreFormatted || copier.logDirProps().isEmpty)) {
|
if (!(ignoreFormatted || copier.logDirProps().isEmpty)) {
|
||||||
val firstLogDir = copier.logDirProps().keySet().iterator().next()
|
val firstLogDir = copier.logDirProps().keySet().iterator().next()
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue