File tree Expand file tree Collapse file tree 3 files changed +3
-3
lines changed
kyuubi-server/src/main/scala/org/apache/kyuubi Expand file tree Collapse file tree 3 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -78,7 +78,7 @@ case class Metadata(
78
78
engineState : String = null ,
79
79
engineError : Option [String ] = None ,
80
80
endTime : Long = 0L ,
81
- priority : Option [ Int ] = None ,
81
+ priority : Int = 10 ,
82
82
peerInstanceClosed : Boolean = false ) {
83
83
def appMgrInfo : ApplicationManagerInfo = {
84
84
ApplicationManagerInfo (
Original file line number Diff line number Diff line change @@ -179,7 +179,7 @@ class KyuubiBatchSession(
179
179
createTime = createTime,
180
180
engineType = batchType,
181
181
clusterManager = batchJobSubmissionOp.builder.clusterManager(),
182
- priority = conf.get(KYUUBI_BATCH_PRIORITY ).map(_.toInt))
182
+ priority = conf.get(KYUUBI_BATCH_PRIORITY ).map(_.toInt).getOrElse( 10 ) )
183
183
184
184
// there is a chance that operation failed w/ duplicated key error
185
185
sessionManager.insertMetadata(newMetadata)
Original file line number Diff line number Diff line change @@ -238,7 +238,7 @@ class KyuubiSessionManager private (name: String) extends SessionManager(name) {
238
238
requestArgs = batchRequest.getArgs.asScala.toSeq,
239
239
createTime = System .currentTimeMillis(),
240
240
engineType = batchRequest.getBatchType,
241
- priority = conf.get(KYUUBI_BATCH_PRIORITY ).map(_.toInt))
241
+ priority = conf.get(KYUUBI_BATCH_PRIORITY ).map(_.toInt).getOrElse( 10 ) )
242
242
243
243
// there is a chance that operation failed w/ duplicated key error
244
244
metadataManager.foreach(_.insertMetadata(metadata, asyncRetryOnError = false ))
You can’t perform that action at this time.
0 commit comments