[kylin] branch kylin-on-parquet-v2 updated: KYLIN-4541 Optimizing the error information in job build

[xxyu]

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

xxyu pushed a commit to branch kylin-on-parquet-v2
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/kylin-on-parquet-v2 by this 
push:
     new 95e46db  KYLIN-4541 Optimizing the error information in job build
95e46db is described below

commit 95e46db70586fb6754f9fd5564140042e1941f25
Author: yaqian.zhang <598593...@qq.com>
AuthorDate: Mon Jun 15 19:18:18 2020 +0800

    KYLIN-4541 Optimizing the error information in job build
---
 .../scala/org/apache/kylin/cluster/parser/FairSchedulerParser.scala     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/kylin/cluster/parser/FairSchedulerParser.scala
 
b/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/kylin/cluster/parser/FairSchedulerParser.scala
index 0e5cfc1..197b3d5 100644
--- 
a/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/kylin/cluster/parser/FairSchedulerParser.scala
+++ 
b/kylin-spark-project/kylin-spark-engine/src/main/scala/org/apache/kylin/cluster/parser/FairSchedulerParser.scala
@@ -38,7 +38,7 @@ class FairSchedulerParser extends SchedulerParser {
   private def queueAvailableResource(queueName: String): AvailableResource = {
     val queues: JList[JsonNode] = root.findParents("queueName")
     val nodes = queues.asScala.filter(queue => 
parseValue(queue.get("queueName")).equals(queueName))
-    require(nodes.size == 1)
+    require(nodes.size == 1, s"Error occurred when check queue $queueName 
available resource. Ignore it.")
     val resource = calAvailableResource(nodes.head)
     logInfo(s"Queue available resource: $resource.")
     resource