Skip to content

Commit

Permalink
log batch state if there is no log
Browse files Browse the repository at this point in the history
  • Loading branch information
turboFei committed Dec 9, 2022
1 parent 8305d80 commit bb908b1
Showing 1 changed file with 5 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -81,6 +81,11 @@ class LogBatchCommand(
}

if (!done) {
if (!Option(log).exists(_.getRowCount > 0)) {
Option(batch).foreach { batch =>
info(s"Batch report for ${batch.getId} (state: ${batch.getState})")
}
}
Thread.sleep(conf.get(CTL_BATCH_LOG_QUERY_INTERVAL))
}
}
Expand Down

0 comments on commit bb908b1

Please sign in to comment.