diff --git a/core/src/main/java/io/javaoperatorsdk/webhook/conversion/AsyncConversionController.java b/core/src/main/java/io/javaoperatorsdk/webhook/conversion/AsyncConversionController.java index bc9d08ca..3d3e9922 100644 --- a/core/src/main/java/io/javaoperatorsdk/webhook/conversion/AsyncConversionController.java +++ b/core/src/main/java/io/javaoperatorsdk/webhook/conversion/AsyncConversionController.java @@ -18,7 +18,7 @@ public class AsyncConversionController implements AsyncConversionRequestHandler { - private static final Logger log = LoggerFactory.getLogger(ConversionController.class); + private static final Logger log = LoggerFactory.getLogger(AsyncConversionController.class); @SuppressWarnings("rawtypes") private final Map mappers = new HashMap<>(); @@ -54,7 +54,7 @@ private CompletionStage> convertObjects(List obje String targetVersion) { CompletableFuture[] completableFutures = new CompletableFuture[objects.size()]; for (int i = 0; i < objects.size(); i++) { - completableFutures[i] = mapObject((HasMetadata) objects.get(i), targetVersion); + completableFutures[i] = mapObject(objects.get(i), targetVersion); } return CompletableFuture.allOf(completableFutures).thenApply(r -> { List result = new ArrayList<>(completableFutures.length); @@ -79,7 +79,6 @@ private CompletableFuture mapObject(HasMetadata resource, String ta return sourceToHubMapper.toHub(resource) .thenApply(r -> hubToTarget.fromHub(r).toCompletableFuture().join()) .toCompletableFuture(); - } }