diff --git a/airbyte-workers/src/main/java/io/airbyte/workers/process/KubePodProcess.java b/airbyte-workers/src/main/java/io/airbyte/workers/process/KubePodProcess.java
index 80c6f5c17c85..649dcd3afbec 100644
--- a/airbyte-workers/src/main/java/io/airbyte/workers/process/KubePodProcess.java
+++ b/airbyte-workers/src/main/java/io/airbyte/workers/process/KubePodProcess.java
@@ -679,7 +679,7 @@ private Container getMainContainerFromPodDefinition() {
     final Optional<Container> containerOptional = podDefinition.getSpec()
         .getContainers()
         .stream()
-        .filter(c -> c.getName().contentEquals(MAIN_CONTAINER_NAME))
+        .filter(c -> MAIN_CONTAINER_NAME.equals(c.getName()))
         .findFirst();
     if (containerOptional.isEmpty()) {
       LOGGER.warn(String.format("Could not find main container definition for pod: %s", podDefinition.getMetadata().getName()));