return rpcConsumerRegistry.getRpcService(ClusterAdminService.class)
.makeLeaderLocal(new MakeLeaderLocalInputBuilder()
.setShardName(shardName)
- .setDataStoreType(DataStoreType.forName(dataStoreType).orElse(null))
+ .setDataStoreType(DataStoreType.forName(dataStoreType))
.build());
}
}