From acd765cb226d01a78e912decf490d1093016b161 Mon Sep 17 00:00:00 2001
From: chaokunyang <shawn.ck.yang@gmail.com>
Date: Tue, 23 Jun 2020 11:57:06 +0800
Subject: [PATCH] [Streaming] fix source loop (#9085)

---
 .../ray/streaming/runtime/worker/tasks/SourceStreamTask.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git a/streaming/java/streaming-runtime/src/main/java/io/ray/streaming/runtime/worker/tasks/SourceStreamTask.java b/streaming/java/streaming-runtime/src/main/java/io/ray/streaming/runtime/worker/tasks/SourceStreamTask.java
index 64fa332e0..c47fe63ae 100644
--- a/streaming/java/streaming-runtime/src/main/java/io/ray/streaming/runtime/worker/tasks/SourceStreamTask.java
+++ b/streaming/java/streaming-runtime/src/main/java/io/ray/streaming/runtime/worker/tasks/SourceStreamTask.java
@@ -30,9 +30,7 @@ public class SourceStreamTask extends StreamTask {
   public void run() {
     LOG.info("Source stream task thread start.");
 
-    while (running) {
-      sourceProcessor.run();
-    }
+    sourceProcessor.run();
   }
 
   @Override