return rpcConsumerRegistry.getRpcService(ClusterAdminService.class)
.removeShardReplica(new RemoveShardReplicaInputBuilder()
.setShardName(shardName)
- .setDataStoreType(DataStoreType.forName(dataStoreType).orElse(null))
+ .setDataStoreType(DataStoreType.forName(dataStoreType))
.setMemberName(memberName)
.build());
}