[incubator-streampark] branch dev updated: Correct doStart() method comment message. (#2787)

[benjobs]

This is an automated email from the ASF dual-hosted git repository.

benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git


The following commit(s) were added to refs/heads/dev by this push:
     new d058634b8 Correct doStart() method comment message. (#2787)
d058634b8 is described below

commit d058634b8adc7213c7482f18040dbf96fa509752
Author: lvlin241 <lvlin...@163.com>
AuthorDate: Thu Jun 1 16:18:47 2023 +0800

    Correct doStart() method comment message. (#2787)
    
    Co-authored-by: lvlin241 <lo...@chinatelecom.cn>
---
 .../streampark/flink/kubernetes/watcher/FlinkJobStatusWatcher.scala     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkJobStatusWatcher.scala
 
b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkJobStatusWatcher.scala
index 55be3f9de..00242aff5 100644
--- 
a/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkJobStatusWatcher.scala
+++ 
b/streampark-flink/streampark-flink-kubernetes/src/main/scala/org/apache/streampark/flink/kubernetes/watcher/FlinkJobStatusWatcher.scala
@@ -68,7 +68,7 @@ class FlinkJobStatusWatcher(conf: JobStatusWatcherConfig = 
JobStatusWatcherConfi
   private val timerExec = Executors.newSingleThreadScheduledExecutor()
   private var timerSchedule: ScheduledFuture[_] = _
 
-  /** stop watcher process */
+  /** start watcher process */
   override def doStart(): Unit = {
     timerSchedule =
       timerExec.scheduleAtFixedRate(() => doWatch(), 0, 
conf.requestIntervalSec, TimeUnit.SECONDS)