From fba663f3f4bcc8b287de788a0299f92db21ee2fa Mon Sep 17 00:00:00 2001
From: xxchan <xxchan22f@gmail.com>
Date: Sat, 20 Apr 2024 17:10:58 +0800
Subject: [PATCH] clean

Signed-off-by: xxchan <xxchan22f@gmail.com>
---
 src/stream/src/executor/source/source_executor.rs | 2 --
 1 file changed, 2 deletions(-)

diff --git a/src/stream/src/executor/source/source_executor.rs b/src/stream/src/executor/source/source_executor.rs
index 951bca8fd44b4..764cc3177f33a 100644
--- a/src/stream/src/executor/source/source_executor.rs
+++ b/src/stream/src/executor/source/source_executor.rs
@@ -458,8 +458,6 @@ impl<S: StateStore> SourceExecutor<S> {
                         boot_state.clone_from(splits);
                     }
                 }
-                // XXX: When the source executor is newly created, the first barrier must be Add or Update (created during scaling).
-                // But when restarting the cluster, is it possible that the first barrier is an Add adding dispatchers?
                 _ => {}
             }
         }