diff --git a/linkis-computation-governance/linkis-manager/linkis-application-manager/pom.xml b/linkis-computation-governance/linkis-manager/linkis-application-manager/pom.xml
index 289939aa3c..9d3cc8a048 100644
--- a/linkis-computation-governance/linkis-manager/linkis-application-manager/pom.xml
+++ b/linkis-computation-governance/linkis-manager/linkis-application-manager/pom.xml
@@ -115,6 +115,11 @@
       <scope>provided</scope>
     </dependency>
 
+    <dependency>
+      <groupId>org.apache.linkis</groupId>
+      <artifactId>linkis-computation-governance-common</artifactId>
+      <version>${project.version}</version>
+    </dependency>
   </dependencies>
 
   <build>
diff --git a/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/restful/EMRestfulApi.java b/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/restful/EMRestfulApi.java
index 1ed66173d4..807facb73a 100644
--- a/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/restful/EMRestfulApi.java
+++ b/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/restful/EMRestfulApi.java
@@ -20,6 +20,8 @@
 import org.apache.linkis.common.ServiceInstance;
 import org.apache.linkis.common.conf.Configuration;
 import org.apache.linkis.common.utils.JsonUtils;
+import org.apache.linkis.governance.common.protocol.conf.TenantRequest;
+import org.apache.linkis.governance.common.protocol.conf.TenantResponse;
 import org.apache.linkis.manager.am.conf.AMConfiguration;
 import org.apache.linkis.manager.am.converter.DefaultMetricsConverter;
 import org.apache.linkis.manager.am.exception.AMErrorCode;
@@ -29,22 +31,31 @@
 import org.apache.linkis.manager.am.service.em.ECMOperateService;
 import org.apache.linkis.manager.am.service.em.EMInfoService;
 import org.apache.linkis.manager.am.utils.AMUtils;
+import org.apache.linkis.manager.am.vo.ConfigVo;
 import org.apache.linkis.manager.am.vo.EMNodeVo;
 import org.apache.linkis.manager.common.entity.enumeration.NodeHealthy;
 import org.apache.linkis.manager.common.entity.metrics.NodeHealthyInfo;
 import org.apache.linkis.manager.common.entity.node.EMNode;
 import org.apache.linkis.manager.common.entity.node.EngineNode;
 import org.apache.linkis.manager.common.entity.persistence.ECResourceInfoRecord;
+import org.apache.linkis.manager.common.entity.persistence.PersistenceLabelRel;
+import org.apache.linkis.manager.common.entity.persistence.PersistenceResource;
 import org.apache.linkis.manager.common.protocol.OperateRequest$;
 import org.apache.linkis.manager.common.protocol.em.ECMOperateRequest;
 import org.apache.linkis.manager.common.protocol.em.ECMOperateRequest$;
 import org.apache.linkis.manager.common.protocol.em.ECMOperateResponse;
+import org.apache.linkis.manager.exception.PersistenceErrorException;
 import org.apache.linkis.manager.label.builder.factory.LabelBuilderFactory;
 import org.apache.linkis.manager.label.builder.factory.LabelBuilderFactoryContext;
 import org.apache.linkis.manager.label.entity.Label;
 import org.apache.linkis.manager.label.entity.UserModifiable;
 import org.apache.linkis.manager.label.exception.LabelErrorException;
 import org.apache.linkis.manager.label.service.NodeLabelService;
+import org.apache.linkis.manager.persistence.LabelManagerPersistence;
+import org.apache.linkis.manager.persistence.ResourceManagerPersistence;
+import org.apache.linkis.manager.rm.restful.vo.UserResourceVo;
+import org.apache.linkis.manager.rm.utils.RMUtils;
+import org.apache.linkis.rpc.Sender;
 import org.apache.linkis.server.Message;
 import org.apache.linkis.server.utils.ModuleUserUtils;
 
@@ -52,6 +63,10 @@
 import org.apache.commons.lang3.ArrayUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.commons.lang3.exception.ExceptionUtils;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.util.EntityUtils;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.transaction.annotation.Transactional;
@@ -59,6 +74,7 @@
 
 import javax.servlet.http.HttpServletRequest;
 
+import java.io.IOException;
 import java.text.MessageFormat;
 import java.util.*;
 import java.util.stream.Collectors;
@@ -67,6 +83,7 @@
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiImplicitParam;
@@ -95,6 +112,11 @@ public class EMRestfulApi {
   @Autowired private ECMOperateService ecmOperateService;
 
   @Autowired private ECResourceInfoService ecResourceInfoService;
+
+  @Autowired private ResourceManagerPersistence resourceManagerPersistence;
+
+  @Autowired private LabelManagerPersistence labelManagerPersistence;
+
   private LabelBuilderFactory stdLabelBuilderFactory =
       LabelBuilderFactoryContext.getLabelBuilderFactory();
 
@@ -492,4 +514,105 @@ private Message executeECMOperation(
         .data("errorMsg", engineOperateResponse.errorMsg())
         .data("isError", engineOperateResponse.isError());
   }
+
+  @ApiOperationSupport(ignoreParameters = {"jsonNode"})
+  @RequestMapping(path = "/taskprediction", method = RequestMethod.GET)
+  public Message taskprediction(
+      HttpServletRequest req,
+      @RequestParam(value = "username", required = false) String username,
+      @RequestParam(value = "engineType", required = false) String engineType,
+      @RequestParam(value = "creator", required = false) String creator,
+      @RequestParam(value = "queueName", required = false) String queueName,
+      @RequestParam(value = "tenant", required = false) String tenant)
+      throws PersistenceErrorException {
+    //    String userName = ModuleUserUtils.getOperationUser(req, "taskprediction");
+    String tokenName = "";
+    if (StringUtils.isBlank(username)) {
+      username = tokenName;
+    }
+    if (StringUtils.isBlank(engineType)) {
+      Message.error("parameters:engineType can't be null (请求参数【engineType】不能为空)");
+    }
+    if (StringUtils.isBlank(creator)) {
+      Message.error("parameters:creator can't be null (请求参数【creator】不能为空)");
+    }
+    // 获取yarn资源数据和用户资源数据
+    String labelValuePattern =
+        MessageFormat.format("%{0}%,%{1}%,%{2}%,%", creator, username, engineType);
+    List<PersistenceLabelRel> userLabels =
+        labelManagerPersistence.getLabelByPattern(
+            labelValuePattern, RMUtils.getCombinedLabel(), 0, 0);
+    List<PersistenceResource> resources =
+        resourceManagerPersistence.getResourceByLabels(userLabels);
+    ArrayList<UserResourceVo> userResources = RMUtils.getUserResources(userLabels, resources);
+
+    // 获取租户标签数据
+    if (StringUtils.isBlank(tenant)) {
+      Sender sender =
+          Sender.getSender(
+              Configuration.CLOUD_CONSOLE_CONFIGURATION_SPRING_APPLICATION_NAME().getValue());
+      TenantResponse response = (TenantResponse) sender.ask(new TenantRequest(username, creator));
+      if (StringUtils.isBlank(response.tenant())) {
+        response = (TenantResponse) sender.ask(new TenantRequest(username, "*"));
+        if (StringUtils.isBlank(response.tenant())) {
+          response = (TenantResponse) sender.ask(new TenantRequest("*", creator));
+        }
+      }
+      tenant = response.tenant();
+    }
+
+    // 获取ecm列表数据
+    List<EMNodeVo> emNodeVos = AMUtils.copyToEMVo(emInfoService.getAllEM());
+    String finalTenant = tenant;
+    List<EMNodeVo> collect =
+        emNodeVos.stream()
+            .filter(
+                emNodeVo -> {
+                  Stream<Label> labelStream = emNodeVo.getLabels().stream();
+                  if (StringUtils.isNotBlank(finalTenant)) {
+                    return labelStream.anyMatch(
+                        label ->
+                            KEY_TENANT.equals(label.getLabelKey())
+                                && label.getStringValue().contains(finalTenant));
+                  } else {
+                    return labelStream.noneMatch(label -> KEY_TENANT.equals(label.getLabelKey()));
+                  }
+                })
+            .collect(Collectors.toList());
+
+    // 获取配置值
+    String responseStr = "";
+    List<ConfigVo> configlist = new ArrayList<>();
+    try {
+      HttpClient httpClient = HttpClients.createDefault();
+      String url =
+          MessageFormat.format(
+              "/api/rest_j/v1/configuration/getFullTreesByAppName?creator={0}&engineType={1}",
+              creator, engineType);
+      HttpGet httpGet = new HttpGet(Configuration.getGateWayURL() + url);
+      httpGet.addHeader("Token-User", username);
+      httpGet.addHeader("Token-Code", "BML-AUTH");
+      responseStr = EntityUtils.toString(httpClient.execute(httpGet).getEntity());
+      ObjectMapper objectMapper = new ObjectMapper();
+      JsonNode fullTree = objectMapper.readTree(responseStr).get("data").get("fullTree");
+      for (JsonNode node : fullTree) {
+        JsonNode settingsList = node.get("settings");
+        for (JsonNode key : settingsList) {
+          configlist.add(
+              new ConfigVo(
+                  key.get("key").asText(),
+                  key.get("configValue").asText(),
+                  key.get("defaultValue").asText()));
+        }
+      }
+    } catch (IOException e) {
+      e.printStackTrace();
+    }
+
+    return Message.ok()
+        .data("test", userResources)
+        .data("tenant", tenant)
+        .data("test3", collect)
+        .data("test4", configlist);
+  }
 }
diff --git a/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/vo/ConfigVo.java b/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/vo/ConfigVo.java
new file mode 100644
index 0000000000..f5e92f168b
--- /dev/null
+++ b/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/vo/ConfigVo.java
@@ -0,0 +1,64 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.linkis.manager.am.vo;
+
+public class ConfigVo {
+
+  private String key;
+  private String defaultValue;
+  private String configValue;
+
+  public ConfigVo(String key, String defaultValue, String configValue) {
+    this.key = key;
+    this.defaultValue = defaultValue;
+    this.configValue = configValue;
+  }
+
+  public String getKey() {
+    return key;
+  }
+
+  public void setKey(String key) {
+    this.key = key;
+  }
+
+  public String getDefaultValue() {
+    return defaultValue;
+  }
+
+  public void setDefaultValue(String defaultValue) {
+    this.defaultValue = defaultValue;
+  }
+
+  public String getConfigValue() {
+    return configValue;
+  }
+
+  public void setConfigValue(String configValue) {
+    this.configValue = configValue;
+  }
+
+  @Override
+  public String toString() {
+    return "ConfigVo{" +
+            "key='" + key + '\'' +
+            ", defaultValue='" + defaultValue + '\'' +
+            ", configValue='" + configValue + '\'' +
+            '}';
+  }
+}
diff --git a/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/utils/RMUtils.scala b/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/utils/RMUtils.scala
index 2b74c31079..932cc56c5d 100644
--- a/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/utils/RMUtils.scala
+++ b/linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/utils/RMUtils.scala
@@ -20,21 +20,29 @@ package org.apache.linkis.manager.rm.utils
 import org.apache.linkis.common.conf.{CommonVars, Configuration, TimeType}
 import org.apache.linkis.common.utils.{ByteTimeUtils, Logging, Utils}
 import org.apache.linkis.manager.common.constant.RMConstant
-import org.apache.linkis.manager.common.entity.persistence.PersistenceResource
+import org.apache.linkis.manager.common.entity.persistence.{
+  PersistenceLabelRel,
+  PersistenceResource
+}
 import org.apache.linkis.manager.common.entity.resource._
 import org.apache.linkis.manager.common.serializer.NodeResourceSerializer
-import org.apache.linkis.manager.label.entity.engine.EngineType
+import org.apache.linkis.manager.common.utils.ResourceUtils
+import org.apache.linkis.manager.label.LabelManagerUtils.labelFactory
+import org.apache.linkis.manager.label.builder.CombinedLabelBuilder
+import org.apache.linkis.manager.label.builder.factory.LabelBuilderFactoryContext
+import org.apache.linkis.manager.label.entity.engine.{EngineType, EngineTypeLabel, UserCreatorLabel}
 import org.apache.linkis.manager.rm.conf.ResourceStatus
-import org.apache.linkis.manager.rm.restful.vo.UserResourceVo
+import org.apache.linkis.manager.rm.restful.vo.{UserCreatorEngineType, UserResourceVo}
 import org.apache.linkis.server.BDPJettyServerHelper
 
 import org.apache.commons.lang3.StringUtils
 
 import java.util
-import java.util.UUID
+import java.util.{List, UUID}
 
 import scala.collection.JavaConverters.asScalaBufferConverter
 
+import com.google.common.collect.Lists
 import org.json4s.DefaultFormats
 import org.json4s.jackson.Serialization.{read, write}
 
@@ -58,7 +66,7 @@ object RMUtils extends Logging {
   val EXTERNAL_RESOURCE_REFRESH_TIME =
     CommonVars("wds.linkis.manager.rm.external.resource.regresh.time", new TimeType("30m"))
 
-  val COMBINED_USERCREATOR_ENGINETYPE = "combined_userCreator_engineType"
+  var COMBINED_USERCREATOR_ENGINETYPE: String = _
 
   val ENGINE_TYPE = CommonVars.apply(
     "wds.linkis.configuration.engine.type",
@@ -254,4 +262,43 @@ object RMUtils extends Logging {
 
   def getECTicketID: String = UUID.randomUUID().toString
 
+  def getCombinedLabel: String = {
+    if (COMBINED_USERCREATOR_ENGINETYPE == null) {
+      val userCreatorLabel = labelFactory.createLabel(classOf[UserCreatorLabel])
+      val engineTypeLabel = labelFactory.createLabel(classOf[EngineTypeLabel])
+      val combinedLabelBuilder = new CombinedLabelBuilder
+      val combinedLabel =
+        combinedLabelBuilder.build("", Lists.newArrayList(userCreatorLabel, engineTypeLabel))
+      COMBINED_USERCREATOR_ENGINETYPE = combinedLabel.getLabelKey
+      COMBINED_USERCREATOR_ENGINETYPE
+    } else {
+      COMBINED_USERCREATOR_ENGINETYPE
+    }
+  }
+
+  def getUserResources(
+      userLabels: util.List[PersistenceLabelRel],
+      resources: util.List[PersistenceResource]
+  ): util.ArrayList[UserResourceVo] = {
+    val userResources = new util.ArrayList[UserResourceVo]()
+    // 4. Store users and resources in Vo
+    resources.asScala.foreach(resource => {
+      val userResource = ResourceUtils.fromPersistenceResourceAndUser(resource)
+      val userLabel = userLabels.asScala.find(_.getResourceId.equals(resource.getId)).orNull
+      if (userLabel != null) {
+        val userCreatorEngineType =
+          BDPJettyServerHelper.gson
+            .fromJson(userLabel.getStringValue, classOf[UserCreatorEngineType])
+        if (userCreatorEngineType != null) {
+          userResource.setUsername(userCreatorEngineType.getUser)
+          userResource.setCreator(userCreatorEngineType.getCreator)
+          userResource.setEngineType(userCreatorEngineType.getEngineType)
+          userResource.setVersion(userCreatorEngineType.getVersion)
+        }
+      }
+      userResources.add(RMUtils.toUserResourceVo(userResource))
+    })
+    userResources
+  }
+
 }