diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java
index <HASH>..<HASH> 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStreamTask.java
@@ -199,9 +199,6 @@ public class SourceStreamTask<
     @Override
     protected void cancelTask() {
         if (stopped.compareAndSet(false, true)) {
-            if (isFailing()) {
-                interruptSourceThread(true);
-            }
             cancelOperator(true);
         }
     }
[hotfix][task] Remove redundant interrupt call

Regardless if task was failing or not, we would still interrupt the source thread
a couple of lines later inside `cancelOperator(true)` -> `interruptSourceThread()`