You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by ca...@apache.org on 2022/04/29 15:51:40 UTC
[incubator-linkis] 03/11: add getJobIdFromStringMap method
This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.1.2
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit 8dc3784395df30bc39dec487c66f2de2b787d052
Author: peacewong <wp...@gmail.com>
AuthorDate: Thu Apr 28 17:34:45 2022 +0800
add getJobIdFromStringMap method
---
.../org/apache/linkis/governance/common/utils/JobUtils.scala | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
diff --git a/linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/utils/JobUtils.scala b/linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/utils/JobUtils.scala
index 1b0638d69..36cc86293 100644
--- a/linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/utils/JobUtils.scala
+++ b/linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/utils/JobUtils.scala
@@ -18,7 +18,6 @@
package org.apache.linkis.governance.common.utils
import org.apache.linkis.governance.common.constant.job.JobRequestConstants
-import org.apache.linkis.protocol.utils.TaskUtils
import java.util;
@@ -34,4 +33,14 @@ object JobUtils {
null
}
+ def getJobIdFromStringMap(map: util.Map[String, String]): String = {
+ if (null != map && map.containsKey(JobRequestConstants.JOB_ID)) {
+ val value = map.get(JobRequestConstants.JOB_ID)
+ if (null != value) {
+ return value
+ }
+ }
+ null
+ }
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org