### Question:
ZkClusterMetadataStore implements ClusterMetadataStore { @Override public boolean initializeCluster(int numStorageContainers, Optional<String> segmentStorePath) { ClusterMetadata metadata = ClusterMetadata.newBuilder() .setNumStorageContainers(numStorageContainers) .build(); ClusterAssignmentData assigmentData = ClusterAssignmentData.newBuilder() .build(); try { BKDLConfig dlogConfig = new BKDLConfig( zkServers, segmentStorePath.orElse(getSegmentsRootPath(zkRootPath))); DLMetadata dlogMetadata = DLMetadata.create(dlogConfig); client.transaction() .forOperations( client.transactionOp().create().forPath(zkRootPath), client.transactionOp().create().forPath(zkClusterMetadataPath, metadata.toByteArray()), client.transactionOp().create().forPath(zkClusterAssignmentPath, assigmentData.toByteArray()), client.transactionOp().create().forPath(getServersPath(zkRootPath)), client.transactionOp().create().forPath(getWritableServersPath(zkRootPath)), client.transactionOp().create().forPath(getStoragePath(zkRootPath), dlogMetadata.serialize())); return true; } catch (Exception e) { if (e instanceof KeeperException.NodeExistsException) { log.info("Stream storage cluster is already initialized."); return false; } throw new StorageRuntimeException("Failed to initialize storage cluster with " + numStorageContainers + " storage containers", e); } } ZkClusterMetadataStore(CuratorFramework client, String zkServers, String zkRootPath); @Override void close(); @Override boolean initializeCluster(int numStorageContainers, Optional<String> segmentStorePath); @Override ClusterAssignmentData getClusterAssignmentData(); @Override void updateClusterAssignmentData(ClusterAssignmentData assigmentData); @Override void watchClusterAssignmentData(Consumer<Void> watcher, Executor executor); @Override void unwatchClusterAssignmentData(Consumer<Void> watcher); @Override ClusterMetadata getClusterMetadata(); @Override void updateClusterMetadata(ClusterMetadata metadata);  }### Answer:
@Test public void testInitialize() { int numStorageContainers = 2048; assertFalse(store.initializeCluster(numStorageContainers)); }