[rocketmq-streams] branch develop updated: move log

[karp]

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

karp pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq-streams.git


The following commit(s) were added to refs/heads/develop by this push:
     new 4a6237eb move log
     new d6b934a8 Merge pull request #258 from ni-ze/develop
4a6237eb is described below

commit 4a6237eb8f41f5dd0ef1e66fddf231c51d51589d
Author: 维章 <uncleran...@gmail.com>
AuthorDate: Sun Jan 22 09:55:44 2023 +0800

    move log
---
 .../java/org/apache/rocketmq/streams/core/running/WorkerThread.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java 
b/core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java
index ae564236..8ea7e0c7 100644
--- 
a/core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java
+++ 
b/core/src/main/java/org/apache/rocketmq/streams/core/running/WorkerThread.java
@@ -92,9 +92,9 @@ public class WorkerThread extends Thread {
     public void run() {
         try {
             this.planetaryEngine.start();
-            this.planetaryEngine.runInLoop();
             logger.info("worker thread=[{}], start task success, jobId:{}", 
this.getName(), jobId);
 
+            this.planetaryEngine.runInLoop();
         } catch (Throwable e) {
             logger.error("worker thread=[{}], error:{}.", this.getName(), e);
             throw new RStreamsException(e);