diff --git a/kyuubi-ctl/src/main/scala/org/apache/kyuubi/ctl/cmd/log/LogBatchCommand.scala b/kyuubi-ctl/src/main/scala/org/apache/kyuubi/ctl/cmd/log/LogBatchCommand.scala index 0ac2093292e..cc051629d43 100644 --- a/kyuubi-ctl/src/main/scala/org/apache/kyuubi/ctl/cmd/log/LogBatchCommand.scala +++ b/kyuubi-ctl/src/main/scala/org/apache/kyuubi/ctl/cmd/log/LogBatchCommand.scala @@ -81,6 +81,12 @@ class LogBatchCommand( } if (!done) { + if (!Option(log).exists(_.getRowCount > 0)) { + Option(batch).foreach { batch => + info(s"Application report for ${batch.getAppId} (state: ${batch.getAppState})," + + s" batch id: $batchId (state: ${batch.getState})") + } + } Thread.sleep(conf.get(CTL_BATCH_LOG_QUERY_INTERVAL)) } }