Merge pull request apache#258 from ni-ze/develop

move log
JargonG96 · Jan 22, 2023 · d6b934a · d6b934a
2 parents 51d13d5 + 4a6237e
commit d6b934a
Showing 1 changed file with 1 addition and 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
@@ -92,9 +92,9 @@ public WorkerThread(String threadName, TopologyBuilder topologyBuilder, Properti
  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);