diff --git a/README-ZH.md b/README-ZH.md
index bcfcfb709b..6a1d9cd148 100644
--- a/README-ZH.md
+++ b/README-ZH.md
@@ -7,7 +7,7 @@
 
 ## 引言
 
-DataSphere Studio（简称DSS）是微众银行自研的一站式数据应用开发管理门户。
+DataSphere Studio（简称DSS）是微众银行自研的数据应用开发管理集成框架。
 
 基于插拔式的集成框架设计，及计算中间件 [**Linkis**](https://github.com/WeBankFinTech/Linkis) ，可轻松接入上层各种数据应用系统，让数据开发变得简洁又易用。
 
@@ -37,170 +37,132 @@ DSS主要特点：
  
         3、数据质量管理工具——[Qualitis](https://github.com/WeBankFinTech/Qualitis)
  
-        4、工作流调度工具——[Azkaban](https://azkaban.github.io/)
+        4、工作流调度工具——[Schedulis](https://github.com/WeBankFinTech/Schedulis)
  
-        **DSS插拔式的框架设计模式，允许用户快速替换DSS已集成的各个Web系统**。如：将Scriptis替换成Zeppelin，将Azkaban替换成DolphinScheduler。
+        5、数据交换工具——[Exchangis](https://github.com/WeBankFinTech/Exchangis) (**已支持免密跳转，等待Exchangis发版**)
+
+        6、数据Api服务——[DataApiService](https://github.com/WeBankFinTech/DataSphereStudio-Doc/blob/main/zh_CN/%E4%BD%BF%E7%94%A8%E6%96%87%E6%A1%A3/DataApiService%E4%BD%BF%E7%94%A8%E6%96%87%E6%A1%A3.md)
+ 
+        7、流式应用开发管理工具——[Streamis](https://github.com/WeBankFinTech/Streamis)(**即将开源**)
+ 
+        **DSS插拔式的框架设计模式，允许用户快速替换DSS已集成的各个Web系统**。如：将 Scriptis 替换成Zeppelin，将 Schedulis 替换成DolphinScheduler。
  
 ![DSS一站式](images/zh_CN/readme/onestop.gif) 
 
-### 二、基于Linkis计算中间件，打造独有的AppJoint设计理念
+### 二、基于Linkis计算中间件，打造独有的AppConn设计理念
 
-        AppJoint，是DSS可以简单快速集成各种上层Web系统的核心概念。
+        AppConn，是DSS可以简单快速集成各种上层Web系统的核心概念。
 
-        AppJoint——应用关节，定义了一套统一的前后台接入规范，可让外部数据应用系统快速简单地接入，成为DSS数据应用开发中的一环。
+        AppConn——应用连接器，定义了一套统一的前后台接入协议，总共分为三级规范，可让外部数据应用系统快速简单地接入，成为DSS数据应用开发中的一环。
+ 
+        AppConn的三级规范即：一级SSO规范，二级组织结构规范，三级开发流程规范；
 
-        DSS通过串联多个AppJoint，编排成一条支持实时执行和定时调度的工作流，用户只需简单拖拽即可完成数据应用的全流程开发。
+        DSS通过串联多个 AppConn，编排成一条支持实时执行和定时调度的工作流，用户只需简单拖拽即可完成数据应用的全流程开发。
 
-        由于AppJoint对接了Linkis，外部数据应用系统因此具备了资源管控、并发限流、用户资源管理等能力，且允许上下文信息跨系统级共享，彻底告别应用孤岛。
+        由于 AppConn 对接了Linkis，外部数据应用系统因此具备了资源管控、并发限流、用户资源管理等能力，且允许上下文信息跨系统级共享，彻底告别应用孤岛。
 
-### 三、Project级管理单元
+### 三、Workspace级管理单元
 
-        以Project为管理单元，组织和管理各数据应用系统的业务应用，定义了一套跨数据应用系统的项目协同开发通用标准。
+        以 Workspace 为管理单元，组织和管理各数据应用系统的业务应用，定义了一套跨数据应用系统的工作空间协同开发通用标准，并提供了用户角色管理能力。
 
 ### 四、已集成的数据应用组件
 
-        DSS通过实现多个AppJoint，已集成了丰富多样的各种上层数据应用系统，基本可满足用户的数据开发需求。
-
-        **用户如果有需要，也可以轻松集成新的数据应用系统，以替换或丰富DSS的数据应用开发流程。**
-
-        1、DSS的调度能力——Azkaban AppJoint
-
-           用户的很多数据应用，通常希望具备周期性的调度能力。
-                                                 
-           目前市面上已有的开源调度系统，与上层的其他数据应用系统整合度低，且难以融通。
-                                                 
-           DSS通过实现Azkaban AppJoint，允许用户将一个编排好的工作流，一键发布到Azkaban中进行定时调度。
-                                                 
-           DSS还为调度系统定义了一套标准且通用的DSS工作流解析发布规范，让其他调度系统可以轻松与DSS实现低成本对接。
-                                                 
-![Azkaban](images/zh_CN/readme/Azkaban_AppJoint.gif)
-
-        2、数据开发——Scriptis AppJoint
-
-           什么是[Scriptis](https://github.com/WeBankFinTech/Scriptis)?
-                                                 
-           Scriptis是一款支持在线写SQL、Pyspark、HiveQL等脚本，提交给[Linkis](https://github.com/WeBankFinTech/Linkis)执行的数据分析Web工具，且支持UDF、函数、资源管控和智能诊断等企业级特性。
-                                                
-           Scriptis AppJoint为DSS集成了Scriptis的数据开发能力，并允许Scriptis的各种脚本类型，作为DSS工作流的节点，参与到应用开发的流程中。
-                                                
-           目前已支持HiveSQL、SparkSQL、Pyspark、Scala等脚本节点类型。
-                                                
-![Scriptis](images/zh_CN/readme/Scriptis_AppJoint.gif)
-
-        3、数据可视化——Visualis AppJoint
-
-           什么是Visualis?
-                                                 
-           Visualis是一个基于宜信开源项目Davinci二次开发的数据可视化BI工具，为用户在数据安全和权限方面，提供金融级数据可视化能力。
-                                                
-           Visualis AppJoint为DSS集成了Visualis的数据可视化能力，并允许数据大屏和仪表盘，作为DSS工作流的节点，与上游的数据集市关联起来。
-                                                
-![Visualis](images/zh_CN/readme/Visualis_AppJoint.gif)
-
-        4、数据质量——Qualitis AppJoint
-
-           Qualitis AppJoint 为DSS集成数据质量校验能力，将数据质量系统集成到DSS工作流开发中，对数据完整性、正确性等进行校验。
-                                                
-![Qualitis](images/zh_CN/readme/Qualitis_AppJoint.gif)
-
-        5、数据发送——Sender AppJoint
-
-           Sender AppJoint为DSS集成数据发送能力，目前支持SendEmail节点类型，所有其他节点的结果集，都可以通过邮件发送。
-                                                 
-           例如：SendEmail节点可直接将Display数据大屏作为邮件发送出来。
-  
-        6、信号节点——Signal AppJoint
-
-           EventChecker AppJoint用于强化业务与流程之间的解耦和相互关联。
-                                                
-           DataChecker节点：检查库表分区是否存在。
-                                                    
-           EventSender: 跨工作流和工程的消息发送节点。
-                                                 
-           EventReceiver: 跨工作流和工程的消息接收节点。
-   
-        7、功能节点
-   
-           空节点、子工作流节点。
-
-        8、**节点扩展**
- 
-            **根据需要，用户可以简单快速替换DSS已集成的各种功能组件，或新增功能组件。**
+        DSS通过实现多个AppConn，已集成了丰富多样的各种上层数据应用系统，基本可满足用户的数据开发需求。
+
+        **如果有需要，也可以轻松集成新的数据应用系统，以替换或丰富DSS的数据应用开发流程。** [点我了解如何快速集成新的应用系统](https://github.com/WeBankFinTech/DataSphereStudio-Doc/blob/main/zh_CN/%E5%BC%80%E5%8F%91%E6%96%87%E6%A1%A3/%E7%AC%AC%E4%B8%89%E6%96%B9%E7%B3%BB%E7%BB%9F%E6%8E%A5%E5%85%A5DSS%E5%BC%80%E5%8F%91%E6%8C%87%E5%8D%97.md)
+
+| 应用工具     | 描述                                                          | DSS0.X 版本要求                                                           | DSS1.0 版本要求    | 版本规划 |
+| --------------- | -------------------------------------------------------------------- | --------------------------------------------------------------------- | ---------- | ------ |
+| **DataApiService**  | 数据API服务。可快速将SQL脚本发布为一个Restful接口，对外提供Rest访问能力                                  | 不支持 | >=1.0.0 | 已发布 |
+| **Airflow**     | 支持将DSS工作流发布到Airflow进行定时调度                                            | >=0.9.1，尚未合并 | on going | **待规划** |
+| **Streamis**  | 流式应用开发管理工具。支持发布Flink Jar 和 Flink SQL ，提供流式应用的开发调试和生产管理能力，如：启停、状态监控、checkpoint等。 | 不支持 | >=1.0.0 | **即将发布** |
+| **UserManager** | 自动初始化一个DSS新用户所必须的所有用户环境，包含：创建Linux用户、各种用户路径、目录授权等                    |  >=0.9.1 | on going | **待规划** |
+| **EventCheck**  | 提供跨业务、跨工程和跨工作流的信号通信能力。 | >=0.5.0 | >=1.0.0 | 已发布      |
+| **SendEmail**   | 提供数据发送能力，所有其他工作流节点的结果集，都可以通过邮件进行发送 | >=0.5.0 | >=1.0.0 | 已发布  |
+| [**Scriptis**](https://github.com/WeBankFinTech/Scriptis)   | 支持在线写SQL、Pyspark、HiveQL等脚本，提交给[Linkis](https://github.com/WeBankFinTech/Linkis)执行的数据分析Web工具。 | >=0.5.0 | >=1.0.0 | 已发布      |
+| [**Visualis**](https://github.com/WeBankFinTech/Visualis)   | 基于宜信开源项目Davinci二次开发的数据可视化BI工具，为用户在数据安全方面提供金融级数据可视化能力。 | >=0.5.0 | >=1.0.0 | 已发布      |
+| [**Qualitis**](https://github.com/WeBankFinTech/Qualitis)   | 数据质量校验工具，提供数据完整性、正确性等数据校验能力 | >=0.5.0 | >=1.0.0 |  **待发布**      |
+| [**Schedulis**](https://github.com/WeBankFinTech/Schedulis) | 基于Azkaban二次开发的工作流任务调度系统,具备高性能，高可用和多租户资源隔离等金融级特性。 | >=0.5.0 | >=1.0.0 | 已发布      |
+| [**Exchangis**](https://github.com/WeBankFinTech/Exchangis) | 支持对结构化及无结构化的异构数据源之间的数据传输的数据交换平台 | 不支持 | >=1.0.0 | **待发布**      |
+
 
 ## Demo试用环境
 
-       由于DataSphereStudio支持执行脚本风险较高，WeDataSphere Demo环境的隔离没有做完，考虑到大家都在咨询Demo环境，决定向社区先定向发放邀请码，接受企业和组织的试用申请。
+       由于 DataSphereStudio 支持执行脚本风险较高，WeDataSphere Demo环境的隔离没有做完，考虑到大家都在咨询Demo环境，决定向社区先定向发放邀请码，接受企业和组织的试用申请。
 
        如果您想试用Demo环境，请加入DataSphere Studio社区用户群（**加群方式请翻到本文档末尾处**），联系团队成员获取邀请码。
 
-       WeDataSphere Demo环境用户注册页面：https://sandbox.webank.com/wds/dss/#/register
+       DataSphereStudio Demo环境用户注册页面：[点我进入](https://www.ozone.space/wds/dss/#/register)
 
-       WeDataSphere Demo环境登录页面：https://sandbox.webank.com/wds/dss/
+       DataSphereStudio Demo环境登录页面：[点我进入](https://www.ozone.space/wds/dss/#/login)
 
-       我们会尽快解决环境隔离问题，争取早日向社区完全开放WeDataSphere Demo环境。
+       **DataSphereStudio1.0 Demo环境将在近期开放，敬请期待**。
 
-## 与类似系统对比
+## 下载
 
-        DSS是一个引领数据应用开发管理方向的开源项目，开源社区目前尚没有同类产品。
+        请前往 [DSS releases](https://github.com/WeBankFinTech/DataSphereStudio/releases) 页面下载 DSS 的已编译版本或源码包。
 
-## 使用场景
+## 编译和安装部署
 
-        DataSphere Studio适用于以下场景：
+请参照 [编译指引](https://github.com/WeBankFinTech/DataSphereStudio-Doc/blob/main/zh_CN/%E5%BC%80%E5%8F%91%E6%96%87%E6%A1%A3/DSS%E7%BC%96%E8%AF%91%E6%96%87%E6%A1%A3.md) 来编译 DSS 源码。
 
-        1. 正在筹建或初步具备大数据平台能力，但无任何数据应用工具的场景。
+请参考 [安装部署文档](https://github.com/WeBankFinTech/DataSphereStudio-Doc/blob/main/zh_CN/%E5%AE%89%E8%A3%85%E9%83%A8%E7%BD%B2/DSS%E5%8D%95%E6%9C%BA%E9%83%A8%E7%BD%B2%E6%96%87%E6%A1%A3.md) 来部署 DSS。
 
-        2. 已具备大数据基础平台能力，且仅有少数数据应用工具的场景。
+## 示例和使用指引
 
-        3. 已具备大数据基础平台能力，且拥有全部数据应用工具，但工具间尚未打通，用户使用隔离感强、学习成本高的场景。
+请到 [用户使用文档](https://github.com/WeBankFinTech/DataSphereStudio-Doc/blob/main/zh_CN/%E4%BD%BF%E7%94%A8%E6%96%87%E6%A1%A3/DSS%E7%94%A8%E6%88%B7%E6%89%8B%E5%86%8C.md) ，了解如何快速使用DSS。
 
-        4. 已具备大数据基础平台能力，且拥有全部数据应用工具，部分工具已实现对接，但尚未定义统一规范的场景。
+## 文档
 
-## 快速安装使用
+DSS1.0的完整文档列表，请参见 [DSS-Doc](https://github.com/WeBankFinTech/DataSphereStudio-Doc/tree/main/zh_CN)
 
-点我进入[快速安装使用](docs/zh_CN/ch2/DSS_LINKIS_Quick_Install.md)
+以下为 DSS 相关 AppConn 插件的安装指南：
 
-## 架构
+- [DSS的Visualis AppConn插件安装指南](https://github.com/WeBankFinTech/DataSphereStudio-Doc/blob/main/zh_CN/%E5%AE%89%E8%A3%85%E9%83%A8%E7%BD%B2/VisualisAppConn%E6%8F%92%E4%BB%B6%E5%AE%89%E8%A3%85%E6%96%87%E6%A1%A3.md)
 
-![DSS架构](images/zh_CN/readme/architecture.png)
+- [DSS的Schedulis AppConn插件安装指南](https://github.com/WeBankFinTech/DataSphereStudio-Doc/blob/main/zh_CN/%E5%AE%89%E8%A3%85%E9%83%A8%E7%BD%B2/SchedulisAppConn%E6%8F%92%E4%BB%B6%E5%AE%89%E8%A3%85%E6%96%87%E6%A1%A3.md)
 
-## 文档列表
+- [DSS的Qualitis AppConn插件安装指南](https://github.com/WeBankFinTech/DataSphereStudio-Doc/blob/main/zh_CN/%E5%AE%89%E8%A3%85%E9%83%A8%E7%BD%B2/QualitisAppConn%E6%8F%92%E4%BB%B6%E5%AE%89%E8%A3%85%E6%96%87%E6%A1%A3.md)
 
-#### 1. 安装编译文档
+- [DSS的Exchangis AppConn插件安装指南](https://github.com/WeBankFinTech/DataSphereStudio-Doc/blob/main/zh_CN/%E5%AE%89%E8%A3%85%E9%83%A8%E7%BD%B2/ExchangisAppConn%E6%8F%92%E4%BB%B6%E5%AE%89%E8%A3%85%E6%96%87%E6%A1%A3.md)
 
-[快速安装使用文档](docs/zh_CN/ch2/DSS_LINKIS_Quick_Install.md)
 
-[**DSS安装常见问题列表**](docs/zh_CN/ch1/DSS安装常见问题列表.md)
+## 架构
 
-[DSS编译文档](docs/zh_CN/ch1/DSS编译文档.md)
+![DSS架构](images/zh_CN/readme/architecture.png)
 
-#### 2. 使用文档
 
-[快速使用文档](docs/zh_CN/ch3/DataSphere_Studio_QuickStart.md)
+## 使用场景
 
-[用户手册](docs/zh_CN/ch3/DSS_User_Manual.md)
+        DataSphere Studio适用于以下场景：
 
-#### 3. AppJoint插件安装文档
+        1. 正在筹建或初步具备大数据平台能力，但无任何数据应用工具的场景。
 
-**以下为手动安装相关插件的指南，DSS一键安装【标准版】已自动安装了以下插件，可忽略。**
+        2. 已具备大数据基础平台能力，且仅有少数数据应用工具的场景。
 
-[DSS的Azkaban AppJoint插件安装指南](docs/zh_CN/ch4/如何接入调度系统Azkaban.md)
+        3. 已具备大数据基础平台能力，且拥有全部数据应用工具，但工具间尚未打通，用户使用隔离感强、学习成本高的场景。
 
-[DSS的Qualitis AppJoint插件安装指南](https://github.com/WeBankFinTech/Qualitis/blob/master/docs/zh_CN/ch1/%E6%8E%A5%E5%85%A5%E5%B7%A5%E4%BD%9C%E6%B5%81%E6%8C%87%E5%8D%97.md)
+        4. 已具备大数据基础平台能力，且拥有全部数据应用工具，部分工具已实现对接，但尚未定义统一规范的场景。
 
-#### 4. 第三方系统如何接入文档
 
-[DSS如何快速集成第三方系统](docs/zh_CN/ch4/第三方系统接入DSS指南.md)
+## 贡献
 
-#### 5. 架构文档
+我们非常欢迎和期待更多的贡献者参与共建 DSS, 不论是代码、文档，或是其他能够帮助到社区的贡献形式。
 
-[DSS工程发布到调度系统的架构设计](docs/zh_CN/ch4/DSS工程发布调度系统架构设计.md)
+## 联系我们
 
-更多文档，敬请期待！
+对 DSS 的任何问题和建议，敬请提交issue，以便跟踪处理和经验沉淀共享。
 
-## 交流贡献
+您也可以扫描下面的二维码，加入我们的微信/QQ群，以获得更快速的响应。
 
 ![交流](images/zh_CN/readme/communication.png)
 
+## 谁在使用 DSS
+
+我们创建了 [Who is using DSS](https://github.com/WeBankFinTech/DataSphereStudio/issues/1) issue 以便用户反馈和记录谁在使用 DSS，欢迎您注册登记.
+
+DSS 自2019年开源发布以来，累计已有700多家试验企业和1000+沙盒试验用户，涉及金融、电信、制造、互联网等多个行业。
+
 ## License
 
 DSS is under the Apache 2.0 license. See the [License](LICENSE) file for details.
diff --git a/README.md b/README.md
index a3bfcfe4e9..f37d3639da 100644
--- a/README.md
+++ b/README.md
@@ -33,19 +33,21 @@ Please be patient, it will take some time to load gif.
  
         c. [Qualitis](https://github.com/WeBankFinTech/Qualitis) - Data Quality Management Tool
  
-        d. [Azkaban](https://azkaban.github.io/) - Batch workflow job scheduler
+        d. [Schedulis](https://github.com/WeBankFinTech/Schedulis) - Batch workflow job scheduler
+
+        f. [Exchangis](https://github.com/WeBankFinTech/Exchangis) - Data Exchange Tool
  
 ![DSS one-stop video](images/en_US/readme/onestop.gif) 
 
-### 2. AppJoint, based on Linkis，defines a unique design concept
+### 2. AppConn, based on Linkis，defines a unique design concept
 
-        AppJoint——application joint, defining unified front-end and back-end 
+        AppConn——application connector, defining unified front-end and back-end 
                             integration specifications, can quickly and easily integrate with external data application systems, 
                             making them as part of DSS data application development.
 
-        DSS arranges multiple AppJoints in series to form a workflow that supports real-time execution and scheduled execution. Users can complete the entire process development of data applications with simple drag and drop operations.
+        DSS arranges multiple AppConns in series to form a workflow that supports real-time execution and scheduled execution. Users can complete the entire process development of data applications with simple drag and drop operations.
 
-        Since AppJoint is integrated with Linkis, the external data application system shares the capabilities of resource management, concurrent limiting, and high performance. AppJoint also allows sharable context across system level and completely gets away from application silos.
+        Since AppConn is integrated with Linkis, the external data application system shares the capabilities of resource management, concurrent limiting, and high performance. AppConn also allows sharable context across system level and completely gets away from application silos.
 
 ### 3. Project, as the management unit
 
@@ -53,55 +55,55 @@ Please be patient, it will take some time to load gif.
 
 ### 4. Integrated data application components
 
-       a. Azkaban AppJoint —— Batch workflow job scheduler
+       a. Schedulis AppConn —— Batch workflow job scheduler
 
          Many data applications developed by users usually require periodic scheduling capability.
                                                  
          At present, the open source scheduling system in the community is pretty unfriendly to integrate with other data application systems.
                                                  
-         DSS implements Azkaban AppJoint, which allows users to publish DSS workflows to Azkaban for regular scheduling.
+         DSS implements Schedulis AppConn, which allows users to publish DSS workflows to Azkaban for regular scheduling.
                                                  
          DSS also defines standard and generic workflow parsing and publishing specifications for scheduling systems, allowing other scheduling systems to easily achieve low-cost integration with DSS.
                                                  
 ![Azkaban](images/en_US/readme/Azkaban_AppJoint.gif)
 
-       b. Scriptis AppJoint —— Data Development IDE Tool
+       b. Scriptis AppConn —— Data Development IDE Tool
 
          What is [Scriptis](https://github.com/WeBankFinTech/Scriptis)?
                                                  
          Scriptis is for interactive data analysis with script development(SQL, Pyspark, HiveQL), task submission(Spark, Hive), UDF, function, resource management and intelligent diagnosis.
                                                 
-         Scriptis AppJoint integrates the data development capabilities of Scriptis to DSS, and allows various script types of Scriptis to serve as nodes in the DSS workflow to participate in the application development process.
+         Scriptis AppConn integrates the data development capabilities of Scriptis to DSS, and allows various script types of Scriptis to serve as nodes in the DSS workflow to participate in the application development process.
                                                 
          Currently supports HiveSQL, SparkSQL, Pyspark, Scala and other script node types.
                                                 
 ![Scriptis](images/en_US/readme/Scriptis_AppJoint.gif)
 
-       c. Visualis AppJoint —— Data Visualization Tool
+       c. Visualis AppConn —— Data Visualization Tool
 
          What is [Visualis](https://github.com/WeBankFinTech/Visualis)?
                                                  
          Visualis is a BI tool for data visualization. It provides financial-grade data visualization capabilities on the basis of data security and permissions, based on the open source project Davinci contributed by CreditEase.
                                                 
-         Visualis AppJoint integrates data visualization capabilities to DSS, and allows displays and dashboards, as nodes of DSS workflows, to be associated with upstream data market.
+         Visualis AppConn integrates data visualization capabilities to DSS, and allows displays and dashboards, as nodes of DSS workflows, to be associated with upstream data market.
                                                 
 ![Visualis](images/en_US/readme/Visualis_AppJoint.gif)
 
-       d. Qualitis AppJoint —— Data quality management Tool
+       d. Qualitis AppConn —— Data quality management Tool
 
-         Qualitis AppJoint integrates data quality verification capabilities for DSS, allows Qualitis as a node in DSS workflow
+         Qualitis AppConn integrates data quality verification capabilities for DSS, allows Qualitis as a node in DSS workflow
                                                 
 ![Qualitis](images/en_US/readme/Qualitis_AppJoint.gif)
 
-       e. Data Sender——Sender AppJoint
+       e. Data Sender——Sender AppConn
 
-         Sender AppJoint provides data delivery capability for DSS. Currently it supports the SendEmail node type, and the result sets of all other nodes can be sent via email.
+         Sender AppConn provides data delivery capability for DSS. Currently it supports the SendEmail node type, and the result sets of all other nodes can be sent via email.
                                                  
          For example, the SendEmail node can directly send the screen shot of a display as an email.  
 
-       f. Signal AppJoint —— Signal Nodes
+       f. Signal AppConn —— Signal Nodes
 
-         Signal AppJoint is used to strengthen the correlation between business and process while keeping them decoupled.
+         Signal AppConn is used to strengthen the correlation between business and process while keeping them decoupled.
                                                 
          DataChecker Node：Checks whether a table or partition exists.
                                                     
diff --git a/plugins/azkaban/linkis-jobtype/bin/install.sh b/plugins/azkaban/linkis-jobtype/bin/install.sh
index ff10c0612b..bd29452fd5 100644
--- a/plugins/azkaban/linkis-jobtype/bin/install.sh
+++ b/plugins/azkaban/linkis-jobtype/bin/install.sh
@@ -38,15 +38,16 @@ fi
 
 echo "start to subsitution conf"
 sed -i  "s#jobtype.lib.dir.*#jobtype.lib.dir=$AZKABAN_JOBTYPE_DIR/linkis/lib#g" ${workDir}/private.properties
-sed -i  "s#wds.linkis.gateway.url.*#wds.linkis.gateway.url=$LINKIS_GATEWAY_URL#g" ${workDir}/plugin.properties
+sed -i  "s#wds.linkis.gateway.url.v0.*#wds.linkis.gateway.url.v0=$LINKIS_GATEWAY_URL#g" ${workDir}/plugin.properties
+sed -i  "s#wds.linkis.gateway.url.v1.*#wds.linkis.gateway.url.v1=$LINKIS_GATEWAY_URL#g" ${workDir}/plugin.properties
 sed -i  "s#wds.linkis.client.flow.author.user.token.*#wds.linkis.client.flow.author.user.token=$LINKIS_GATEWAY_TOKEN#g" ${workDir}/plugin.properties
 isSuccess "subsitution conf"
 
 echo "$COPY Plugin"
-ssh  -p $SSH_PORT $AZKABAN_EXECUTOR_HOST "cd $AZKABAN_JOBTYPE_DIR;rm -rf linkis-bak; mv -f linkis ../linkis-bak"
+##ssh  -p $SSH_PORT $AZKABAN_EXECUTOR_HOST "cd $AZKABAN_JOBTYPE_DIR;rm -rf linkis-bak; mv -f linkis ../linkis-bak"
 
 scp   -P $SSH_PORT  -r ${workDir} $AZKABAN_EXECUTOR_HOST:$AZKABAN_JOBTYPE_DIR
 
 echo "reload jobType"
 
-curl $AZKABAN_EXECUTOR_URL
\ No newline at end of file
+##curl $AZKABAN_EXECUTOR_URL
\ No newline at end of file
diff --git a/plugins/azkaban/linkis-jobtype/pom.xml b/plugins/azkaban/linkis-jobtype/pom.xml
index 9d0d787b5a..9c8dfd16ae 100644
--- a/plugins/azkaban/linkis-jobtype/pom.xml
+++ b/plugins/azkaban/linkis-jobtype/pom.xml
@@ -1,9 +1,8 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!--
   ~ Copyright 2019 WeBank
-  ~
   ~ Licensed under the Apache License, Version 2.0 (the "License");
-  ~  you may not use this file except in compliance with 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
@@ -23,12 +22,11 @@
     <parent>
         <artifactId>dss</artifactId>
         <groupId>com.webank.wedatasphere.dss</groupId>
-        <version>0.9.1</version>
+        <version>1.0.0</version>
     </parent>
-    <groupId>com.webank.wedatasphere.dss</groupId>
     <artifactId>linkis-jobtype</artifactId>
     <properties>
-        <azkaban.version>2.5.0</azkaban.version>
+        <azkaban.version>0.6.1</azkaban.version>
     </properties>
 
     <dependencies>
@@ -40,9 +38,19 @@
         </dependency>
 
         <dependency>
-            <groupId>com.linkedin.azkaban</groupId>
-            <artifactId>azkaban</artifactId>
+            <groupId>com.webank.wedatasphere.schedulis</groupId>
+            <artifactId>azkaban-common</artifactId>
             <version>${azkaban.version}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>com.webank.azkaban</groupId>
+                    <artifactId>azkaban-spi</artifactId>
+                </exclusion>
+                <exclusion>
+                    <groupId>com.webank.azkaban</groupId>
+                    <artifactId>azkaban-db</artifactId>
+                </exclusion>
+            </exclusions>
             <scope>provided</scope>
         </dependency>
 
@@ -77,6 +85,11 @@
             </plugin>
             <plugin>
                  <artifactId>maven-assembly-plugin</artifactId>
+                <configuration>
+                    <descriptorRefs>
+                        <descriptorRef>jar-with-dependencies</descriptorRef>
+                    </descriptorRefs>
+                </configuration>
                  <executions>
                      <execution>
                          <id>package</id>
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/AzkabanDssJobType.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/AzkabanDssJobType.java
index f75b6611a6..5e1b864fc7 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/AzkabanDssJobType.java
+++ b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/AzkabanDssJobType.java
@@ -1,8 +1,7 @@
 /*
  * Copyright 2019 WeBank
- *
  * Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with 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
@@ -22,24 +21,24 @@
 import azkaban.utils.Props;
 import com.webank.wedatasphere.dss.linkis.node.execution.conf.LinkisJobExecutionConfiguration;
 import com.webank.wedatasphere.dss.linkis.node.execution.execution.impl.LinkisNodeExecutionImpl;
-import com.webank.wedatasphere.dss.linkis.node.execution.job.LinkisJob;
 import com.webank.wedatasphere.dss.linkis.node.execution.job.Job;
 import com.webank.wedatasphere.dss.linkis.node.execution.job.JobTypeEnum;
+import com.webank.wedatasphere.dss.linkis.node.execution.job.LinkisJob;
 import com.webank.wedatasphere.dss.linkis.node.execution.listener.LinkisExecutionListener;
 import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job.JobBuilder;
-import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.log.AzkabanAppjointLog;
-import org.apache.log4j.Logger;
-import java.util.Map;
+import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.log.AzkabanAppConnLog;
+import org.apache.commons.lang.StringUtils;
+import org.slf4j.Logger;
 
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Map;
 
 
-/**
- * Created by peacewong on 2019/9/19.
- */
 public class AzkabanDssJobType extends AbstractJob {
 
 
-
     private static final String SENSITIVE_JOB_PROP_NAME_SUFFIX = "_X";
     private static final String SENSITIVE_JOB_PROP_VALUE_PLACEHOLDER = "[MASKED]";
     private static final String JOB_DUMP_PROPERTIES_IN_LOG = "job.dump.properties";
@@ -82,23 +81,51 @@ public AzkabanDssJobType(String jobId, Props sysProps, Props jobProps, Logger lo
 
     }
 
+
     @Override
     public void run() throws Exception {
 
         info("Start to execute job");
         logJobProperties();
+        String runDate = getRunDate();
+        if (StringUtils.isNotBlank(runDate)){
+            this.jobPropsMap.put("run_date", runDate);
+        }
         this.job = JobBuilder.getAzkanbanBuilder().setJobProps(this.jobPropsMap).build();
-        this.job.setLogObj(new AzkabanAppjointLog(this.log));
+        this.job.setLogObj(new AzkabanAppConnLog(this.log));
         if(JobTypeEnum.EmptyJob == ((LinkisJob)this.job).getJobType()){
             this.log.warn("This node is empty type");
             return;
         }
+       // info("runtimeMap is " + job.getRuntimeParams());
+        //job.getRuntimeParams().put("workspace", getWorkspace(job.getUser()));
+        info("runtimeMap is " + job.getRuntimeParams());
         LinkisNodeExecutionImpl.getLinkisNodeExecution().runJob(this.job);
-        LinkisNodeExecutionImpl.getLinkisNodeExecution().waitForComplete(this.job);
+
+        try {
+            LinkisNodeExecutionImpl.getLinkisNodeExecution().waitForComplete(this.job);
+        } catch (Exception e) {
+            this.log.warn("Failed to execute job", e);
+            //String reason = LinkisNodeExecutionImpl.getLinkisNodeExecution().getLog(this.job);
+            //this.log.error("Reason for failure: " + reason);
+            throw e;
+        }
+        try {
+            String endLog = LinkisNodeExecutionImpl.getLinkisNodeExecution().getLog(this.job);
+            this.log.info(endLog);
+        } catch (Throwable e){
+            this.log.info("Failed to get log", e);
+        }
 
         LinkisExecutionListener listener = (LinkisExecutionListener)LinkisNodeExecutionImpl.getLinkisNodeExecution();
         listener.onStatusChanged(null,  LinkisNodeExecutionImpl.getLinkisNodeExecution().getState(this.job),this.job);
-        int resultSize =  LinkisNodeExecutionImpl.getLinkisNodeExecution().getResultSize(this.job);
+        int resultSize =  0;
+        try{
+            resultSize = LinkisNodeExecutionImpl.getLinkisNodeExecution().getResultSize(this.job);
+        }catch(final Throwable t){
+            this.log.error("failed to get result size");
+            resultSize = -1;
+        }
         for(int i =0; i < resultSize; i++){
             this.log.info("The content of the " + (i + 1) + "th resultset is :"
                     +  LinkisNodeExecutionImpl.getLinkisNodeExecution().getResult(this.job, i, LinkisJobExecutionConfiguration.RESULT_PRINT_SIZE.getValue(this.jobPropsMap)));
@@ -109,7 +136,7 @@ public void run() throws Exception {
 
     @Override
     public void cancel() throws Exception {
-        super.cancel();
+        //super.cancel();
         LinkisNodeExecutionImpl.getLinkisNodeExecution().cancel(this.job);
         isCanceled = true;
         warn("This job has been canceled");
@@ -149,4 +176,37 @@ private void logJobProperties() {
         }
     }
 
+    private String getRunDate(){
+        this.info("begin to get run date");
+        if (this.jobProps != null &&
+                this.jobProps.getBoolean(JOB_DUMP_PROPERTIES_IN_LOG, true)) {
+            try {
+                for (final Map.Entry<String, String> entry : this.jobPropsMap.entrySet()) {
+                    final String key = entry.getKey();
+                    final String value = key.endsWith(SENSITIVE_JOB_PROP_NAME_SUFFIX) ?
+                            SENSITIVE_JOB_PROP_VALUE_PLACEHOLDER :
+                            entry.getValue();
+                    if ("azkaban.flow.start.timestamp".equals(key)){
+                        this.info("run time is " + value);
+                        String runDateNow = value.substring(0, 10).replaceAll("-", "");
+                        this.info("run date now is " + runDateNow);
+                        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyyMMdd");
+                        try {
+                            Date date = simpleDateFormat.parse(runDateNow);
+                            //因为date已经当天的00:00:00 减掉12小时 就是昨天的时间
+                            String runDate = simpleDateFormat.format(new Date(date.getTime() - 24 * 60 * 60 * 1000));
+                            this.info("runDate is " + runDate);
+                            return runDate;
+                        } catch (ParseException e) {
+                            this.log.error("failed to parse run date " + runDateNow, e);
+                        }
+                    }
+                }
+            } catch (final Exception ex) {
+                this.log.error("failed to log job properties ", ex);
+            }
+        }
+        return null;
+    }
+
 }
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/conf/LinkisJobTypeConf.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/conf/LinkisJobTypeConf.java
index 6c877891be..69d6da0593 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/conf/LinkisJobTypeConf.java
+++ b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/conf/LinkisJobTypeConf.java
@@ -1,8 +1,7 @@
 /*
  * Copyright 2019 WeBank
- *
  * Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with 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
@@ -19,15 +18,15 @@
 
 import com.webank.wedatasphere.linkis.common.conf.CommonVars;
 
-/**
- * Created by peacewong on 2019/11/3.
- */
+
 public class LinkisJobTypeConf {
 
     public static final String COMMAND = "command";
 
     public static final String JOB_ID = "azkaban.job.id";
 
+    public static final String DSS_LABELS_KEY = "labels";
+
     public static final String FLOW_NAME =  "azkaban.flow.flowid";
 
     public static final String PROJECT_ID = "azkaban.flow.projectid";
@@ -41,12 +40,8 @@ public class LinkisJobTypeConf {
 
     public static final String FLOW_SUBMIT_USER = "azkaban.flow.submituser";
 
-    public static final String READ_NODE_TOKEN = "read.nodes";
-
-    public static final String SHARED_NODE_TOKEN = "share.num";
-
     public static final String MSG_SAVE_KEY = "msg.savekey";
 
-    public final static CommonVars<String> SIGNAL_NODES = CommonVars.apply("wds.dss.flow.signal.nodes","linkis.appjoint.eventchecker.eventreceiver");
+    public final static CommonVars<String> SIGNAL_NODES = CommonVars.apply("wds.dss.flow.signal.nodes","linkis.appconn.eventchecker.eventreceiver");
 
 }
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisJob.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppConnLinkisJob.java
similarity index 72%
rename from plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisJob.java
rename to plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppConnLinkisJob.java
index 46064b6f64..3de788c442 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisJob.java
+++ b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppConnLinkisJob.java
@@ -1,8 +1,7 @@
 /*
  * Copyright 2019 WeBank
- *
  * Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with 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
@@ -17,22 +16,15 @@
 
 package com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job;
 
-import com.webank.wedatasphere.dss.linkis.node.execution.job.AbstractAppJointLinkisJob;
+import com.webank.wedatasphere.dss.linkis.node.execution.job.AbstractAppConnLinkisJob;
 import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-import org.apache.commons.lang.StringUtils;
 
 
-/**
- * Created by peacewong on 2019/11/3.
- */
-public class AzkabanAppJointLinkisJob extends AbstractAppJointLinkisJob {
+public class AzkabanAppConnLinkisJob extends AbstractAppConnLinkisJob {
 
 
     @Override
     public String getSubmitUser() {
-        if (StringUtils.isEmpty(getJobProps().get(LinkisJobTypeConf.FLOW_SUBMIT_USER))){
-            return getJobProps().get(LinkisJobTypeConf.PROXY_USER);
-        }
         return getJobProps().get(LinkisJobTypeConf.FLOW_SUBMIT_USER);
     }
 
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisReadJob.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisReadJob.java
deleted file mode 100644
index 6009a97d17..0000000000
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisReadJob.java
+++ /dev/null
@@ -1,56 +0,0 @@
-/*
- * Copyright 2019 WeBank
- *
- * Licensed 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 com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job;
-
-import com.webank.wedatasphere.dss.linkis.node.execution.job.ReadJob;
-import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-
-import java.util.Map;
-
-/**
- * Created by peacewong on 2019/11/3.
- */
-public class AzkabanAppJointLinkisReadJob extends AzkabanAppJointLinkisJob implements ReadJob {
-
-    private Map<String, Object> sharedNodesInfo;
-
-    @Override
-    public Map<String, Object> getSharedNodesInfo() {
-        return this.sharedNodesInfo;
-    }
-
-    @Override
-    public String getSharedKey(String value) {
-        String projectId = getJobProps().get(LinkisJobTypeConf.PROJECT_ID);
-        String flowId = getJobProps().get(LinkisJobTypeConf.FLOW_NAME);
-        String flowExecId = getJobProps().get(LinkisJobTypeConf.FLOW_EXEC_ID);
-        return projectId + "." + flowId + "." + flowExecId + "." + value;
-    }
-
-    @Override
-    public void setSharedNodesInfo(Map<String, Object> sharedNodesInfo) {
-        this.sharedNodesInfo = sharedNodesInfo;
-    }
-
-    @Override
-    public String[] getShareNodeIds() {
-        String nodesStr = getJobProps().get(LinkisJobTypeConf.READ_NODE_TOKEN);
-        String[] nodes = nodesStr.split(",");
-        return nodes;
-    }
-}
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisSharedJob.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisSharedJob.java
deleted file mode 100644
index d3ea1bb823..0000000000
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointLinkisSharedJob.java
+++ /dev/null
@@ -1,47 +0,0 @@
-/*
- * Copyright 2019 WeBank
- *
- * Licensed 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 com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job;
-
-import com.webank.wedatasphere.dss.linkis.node.execution.job.SharedJob;
-import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-
-/**
- * Created by peacewong on 2019/11/3.
- */
-public class AzkabanAppJointLinkisSharedJob extends AzkabanAppJointLinkisJob implements SharedJob {
-
-    private int sharedNum;
-
-    @Override
-    public int getSharedNum() {
-        return this.sharedNum;
-    }
-
-    @Override
-    public String getSharedKey() {
-        String projectId = getJobProps().get(LinkisJobTypeConf.PROJECT_ID);
-        String flowId = getJobProps().get(LinkisJobTypeConf.FLOW_NAME);
-        String flowExecId = getJobProps().get(LinkisJobTypeConf.FLOW_EXEC_ID);
-        String nodeId = getJobProps().get(LinkisJobTypeConf.JOB_ID);
-        return projectId + "." + flowId + "." + flowExecId + "." + nodeId;
-    }
-
-    public void setSharedNum(int sharedNum) {
-        this.sharedNum = sharedNum;
-    }
-}
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointSignalSharedJob.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointSignalSharedJob.java
deleted file mode 100644
index a24adcb69d..0000000000
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanAppJointSignalSharedJob.java
+++ /dev/null
@@ -1,57 +0,0 @@
-/*
- * Copyright 2019 WeBank
- *
- * Licensed 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 com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job;
-
-import com.webank.wedatasphere.dss.linkis.node.execution.job.JobSignalKeyCreator;
-import com.webank.wedatasphere.dss.linkis.node.execution.job.SignalSharedJob;
-import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-
-import java.util.Map;
-
-/**
- * Created by johnnwang on 2019/11/14.
- */
-public class AzkabanAppJointSignalSharedJob extends AzkabanAppJointLinkisJob implements SignalSharedJob {
-
-
-    private JobSignalKeyCreator signalKeyCreator;
-
-    @Override
-    public JobSignalKeyCreator getSignalKeyCreator() {
-        return this.signalKeyCreator;
-    }
-
-    @Override
-    public void setSignalKeyCreator(JobSignalKeyCreator signalKeyCreator) {
-        this.signalKeyCreator = signalKeyCreator;
-    }
-
-    @Override
-    public String getMsgSaveKey() {
-        Map<String, Object> configuration = this.getConfiguration();
-        Object map = configuration.get("runtime");
-        if (map != null && map instanceof Map) {
-            Map<String, Object> runtime = (Map<String, Object>) map;
-            Object msgValue = runtime.get(LinkisJobTypeConf.MSG_SAVE_KEY);
-            if (null != msgValue) {
-                return msgValue.toString();
-            }
-        }
-        return null;
-    }
-}
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisJob.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisJob.java
index cf398810c5..eed1f8109e 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisJob.java
+++ b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisJob.java
@@ -1,8 +1,7 @@
 /*
  * Copyright 2019 WeBank
- *
  * Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with 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
@@ -19,20 +18,13 @@
 
 import com.webank.wedatasphere.dss.linkis.node.execution.job.AbstractCommonLinkisJob;
 import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-import org.apache.commons.lang.StringUtils;
 
 
-/**
- * Created by peacewong on 2019/11/3.
- */
 public class AzkabanCommonLinkisJob extends AbstractCommonLinkisJob {
 
 
     @Override
     public String getSubmitUser() {
-        if (StringUtils.isEmpty(getJobProps().get(LinkisJobTypeConf.FLOW_SUBMIT_USER))){
-            return getJobProps().get(LinkisJobTypeConf.PROXY_USER);
-        }
         return getJobProps().get(LinkisJobTypeConf.FLOW_SUBMIT_USER);
     }
 
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisReadJob.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisReadJob.java
deleted file mode 100644
index fb821b11f9..0000000000
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisReadJob.java
+++ /dev/null
@@ -1,57 +0,0 @@
-/*
- * Copyright 2019 WeBank
- *
- * Licensed 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 com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job;
-
-import com.webank.wedatasphere.dss.linkis.node.execution.job.ReadJob;
-import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-
-import java.util.List;
-import java.util.Map;
-
-/**
- * Created by peacewong on 2019/11/3.
- */
-public class AzkabanCommonLinkisReadJob extends AzkabanCommonLinkisJob implements ReadJob {
-
-    private Map<String, Object> sharedNodesInfo;
-
-    @Override
-    public Map<String, Object> getSharedNodesInfo() {
-        return this.sharedNodesInfo;
-    }
-
-    @Override
-    public String getSharedKey(String value) {
-        String projectId = getJobProps().get(LinkisJobTypeConf.PROJECT_ID);
-        String flowId = getJobProps().get(LinkisJobTypeConf.FLOW_NAME);
-        String flowExecId = getJobProps().get(LinkisJobTypeConf.FLOW_EXEC_ID);
-        return projectId + "." + flowId + "." + flowExecId + "." + value;
-    }
-
-    @Override
-    public void setSharedNodesInfo(Map<String, Object> sharedNodesInfo) {
-        this.sharedNodesInfo = sharedNodesInfo;
-    }
-
-    @Override
-    public  String[] getShareNodeIds() {
-        String nodesStr = getJobProps().get(LinkisJobTypeConf.READ_NODE_TOKEN);
-        String[] nodes = nodesStr.split(",");
-        return nodes;
-    }
-}
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisSharedJob.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisSharedJob.java
deleted file mode 100644
index 2eca7e2809..0000000000
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanCommonLinkisSharedJob.java
+++ /dev/null
@@ -1,47 +0,0 @@
-/*
- * Copyright 2019 WeBank
- *
- * Licensed 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 com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job;
-
-import com.webank.wedatasphere.dss.linkis.node.execution.job.SharedJob;
-import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-
-/**
- * Created by peacewong on 2019/11/3.
- */
-public class AzkabanCommonLinkisSharedJob extends AzkabanCommonLinkisJob implements SharedJob {
-
-    private int sharedNum;
-
-    @Override
-    public int getSharedNum() {
-        return this.sharedNum;
-    }
-
-    @Override
-    public String getSharedKey() {
-        String projectId = getJobProps().get(LinkisJobTypeConf.PROJECT_ID);
-        String flowId = getJobProps().get(LinkisJobTypeConf.FLOW_NAME);
-        String flowExecId = getJobProps().get(LinkisJobTypeConf.FLOW_EXEC_ID);
-        String nodeId = getJobProps().get(LinkisJobTypeConf.JOB_ID);
-        return projectId + "." + flowId + "." + flowExecId + "." + nodeId;
-    }
-
-    public void setSharedNum(int sharedNum) {
-        this.sharedNum = sharedNum;
-    }
-}
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanJobSignalKeyCreator.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanJobSignalKeyCreator.java
deleted file mode 100644
index 30c6a6415f..0000000000
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkabanJobSignalKeyCreator.java
+++ /dev/null
@@ -1,39 +0,0 @@
-/*
- * Copyright 2019 WeBank
- *
- * Licensed 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 com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job;
-
-import com.webank.wedatasphere.dss.linkis.node.execution.job.Job;
-import com.webank.wedatasphere.dss.linkis.node.execution.job.JobSignalKeyCreator;
-import com.webank.wedatasphere.dss.linkis.node.execution.job.SignalSharedJob;
-import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-
-public class AzkabanJobSignalKeyCreator implements JobSignalKeyCreator {
-
-    @Override
-    public String getSignalKeyByJob(Job job) {
-        String projectId = job.getJobProps().get(LinkisJobTypeConf.PROJECT_ID);
-        String flowId = job.getJobProps().get(LinkisJobTypeConf.FLOW_NAME);
-        String flowExecId = job.getJobProps().get(LinkisJobTypeConf.FLOW_EXEC_ID);
-        return projectId + "." + flowId + "." + flowExecId ;
-    }
-
-    @Override
-    public String getSignalKeyBySignalSharedJob(SignalSharedJob job) {
-        return getSignalKeyByJob((Job)job);
-    }
-}
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkanbanBuilder.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkanbanBuilder.java
index c38fac2440..d0ad36e753 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkanbanBuilder.java
+++ b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/AzkanbanBuilder.java
@@ -1,8 +1,7 @@
 /*
  * Copyright 2019 WeBank
- *
  * Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with 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
@@ -17,109 +16,54 @@
 
 package com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job;
 
+import com.google.gson.Gson;
 import com.webank.wedatasphere.dss.linkis.node.execution.conf.LinkisJobExecutionConfiguration;
 import com.webank.wedatasphere.dss.linkis.node.execution.entity.BMLResource;
-import com.webank.wedatasphere.dss.linkis.node.execution.exception.LinkisJobExecutionErrorException;
-import com.webank.wedatasphere.dss.linkis.node.execution.execution.LinkisNodeExecution;
-import com.webank.wedatasphere.dss.linkis.node.execution.execution.impl.LinkisNodeExecutionImpl;
-import com.webank.wedatasphere.dss.linkis.node.execution.job.*;
-import com.webank.wedatasphere.dss.linkis.node.execution.parser.JobParamsParser;
+import com.webank.wedatasphere.dss.linkis.node.execution.job.Builder;
+import com.webank.wedatasphere.dss.linkis.node.execution.job.CommonLinkisJob;
+import com.webank.wedatasphere.dss.linkis.node.execution.job.Job;
+import com.webank.wedatasphere.dss.linkis.node.execution.job.LinkisJob;
+import com.webank.wedatasphere.dss.linkis.node.execution.service.LinkisURLService;
 import com.webank.wedatasphere.dss.linkis.node.execution.utils.LinkisJobExecutionUtils;
 import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.utils.LinkisJobTypeUtils;
-import org.apache.commons.lang.StringUtils;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import org.apache.commons.io.IOUtils;
+import org.apache.http.HttpEntity;
+import org.apache.http.NameValuePair;
+import org.apache.http.client.CookieStore;
+import org.apache.http.client.methods.CloseableHttpResponse;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.protocol.HttpClientContext;
+import org.apache.http.impl.client.BasicCookieStore;
+import org.apache.http.impl.client.CloseableHttpClient;
+import org.apache.http.impl.client.HttpClients;
+import org.apache.http.message.BasicNameValuePair;
+import org.apache.http.util.EntityUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
-import java.util.*;
 
-/**
- * Created by johnnwang on 2019/11/3.
- */
 public class AzkanbanBuilder extends Builder{
 
-    private Map<String, String> jobProps;
+    private static final Logger LOGGER = LoggerFactory.getLogger(AzkanbanBuilder.class);
 
-    private JobSignalKeyCreator jobSignalKeyCreator = new AzkabanJobSignalKeyCreator();
+    private Map<String, String> jobProps;
 
     public AzkanbanBuilder setJobProps(Map<String, String> jobProps) {
         this.jobProps = jobProps;
         return this;
     }
 
-    {
-        init();
-    }
-
-    private void init(){
-        JobParamsParser jobParamsParser = new JobParamsParser();
-        jobParamsParser.setSignalKeyCreator(jobSignalKeyCreator);
-        LinkisNodeExecutionImpl linkisNodeExecution = (LinkisNodeExecutionImpl)LinkisNodeExecutionImpl.getLinkisNodeExecution();
-        linkisNodeExecution.registerJobParser(jobParamsParser);
-    }
-
     @Override
     protected String getJobType() {
         return jobProps.getOrDefault(LinkisJobExecutionConfiguration.LINKIS_TYPE,
                 LinkisJobExecutionConfiguration.LINKIS_DEFAULT_TYPE.getValue(jobProps));
     }
 
-    @Override
-    protected Boolean isReadNode() {
-        return  StringUtils.isNotEmpty(jobProps.get("read.nodes"));
-    }
-
-    @Override
-    protected Boolean isShareNod() {
-        return  StringUtils.isNotEmpty(jobProps.get("share.num"));
-    }
-
-    @Override
-    protected Boolean isSignalSharedNode() {
-        return LinkisJobTypeUtils.isSignalNode(getJobType());
-    }
-
-    @Override
-    protected ReadJob createReadJob(boolean isLinkisType) {
-        if(isLinkisType){
-            AzkabanCommonLinkisReadJob readJob = new AzkabanCommonLinkisReadJob();
-            readJob.setJobProps(this.jobProps);
-            return readJob;
-        } else {
-            AzkabanAppJointLinkisReadJob readJob = new AzkabanAppJointLinkisReadJob();
-            readJob.setJobProps(this.jobProps);
-            return readJob;
-        }
-    }
-
-    @Override
-    protected SharedJob createSharedJob(boolean isLinkisType) {
-        if(isLinkisType){
-            AzkabanCommonLinkisSharedJob sharedJob = new AzkabanCommonLinkisSharedJob();
-            sharedJob.setJobProps(this.jobProps);
-            int shareNum = Integer.parseInt(this.jobProps.get(LinkisJobTypeConf.SHARED_NODE_TOKEN));
-            sharedJob.setSharedNum(shareNum);
-            return sharedJob;
-        } else {
-            AzkabanAppJointLinkisSharedJob sharedJob = new AzkabanAppJointLinkisSharedJob();
-            sharedJob.setJobProps(this.jobProps);
-            int shareNum = Integer.parseInt(this.jobProps.get(LinkisJobTypeConf.SHARED_NODE_TOKEN));
-            sharedJob.setSharedNum(shareNum);
-            return sharedJob;
-        }
-    }
-
-    @Override
-    protected SignalSharedJob createSignalSharedJob(boolean isLinkisType) {
-        if(isLinkisType){
-
-            return null;
-        } else {
-            AzkabanAppJointSignalSharedJob signalSharedJob = new AzkabanAppJointSignalSharedJob();
-            signalSharedJob.setSignalKeyCreator(jobSignalKeyCreator);
-            signalSharedJob.setJobProps(this.jobProps);
-            return signalSharedJob;
-        }
-    }
-
     @Override
     protected LinkisJob creatLinkisJob(boolean isLinkisType) {
         if(isLinkisType){
@@ -127,7 +71,7 @@ protected LinkisJob creatLinkisJob(boolean isLinkisType) {
             linkisJob.setJobProps(this.jobProps);
             return linkisJob;
         } else {
-            AzkabanAppJointLinkisJob linkisJob = new AzkabanAppJointLinkisJob();
+            AzkabanAppConnLinkisJob linkisJob = new AzkabanAppConnLinkisJob();
             linkisJob.setJobProps(this.jobProps);
             return linkisJob;
         }
@@ -136,26 +80,96 @@ protected LinkisJob creatLinkisJob(boolean isLinkisType) {
     @Override
     protected void fillJobInfo(Job job) {
         job.setCode(jobProps.get(LinkisJobTypeConf.COMMAND));
-        job.setParams(new HashMap<String, Object>());
-        job.setRuntimeParams(new HashMap<String, Object>());
+
+        Map<String, Object> params = new HashMap<>();
+        if(jobProps.containsKey("run_date")){
+            params.put("run_date", jobProps.get("run_date"));
+        }
+        job.setParams(params);
+
+        Map<String, Object> runtimeMap = new HashMap<>();
+        if (null != job.getRuntimeParams()){
+            runtimeMap = job.getRuntimeParams();
+        }
+        //update by peaceWong add contextID to runtimeMap
+        if (jobProps.containsKey(LinkisJobExecutionConfiguration.FLOW_CONTEXTID)){
+            runtimeMap.put("contextID", jobProps.get(LinkisJobExecutionConfiguration.FLOW_CONTEXTID).replace("/", "\\"));
+        }
+        runtimeMap.put("nodeName", jobProps.get(LinkisJobTypeConf.JOB_ID));
+
+        runtimeMap.put(LinkisJobTypeConf.DSS_LABELS_KEY, jobProps.get(LinkisJobTypeConf.DSS_LABELS_KEY));
+        //to put a workspace for linkis job
+        String workspace = "";
+        try {
+            workspace = getWorkspace(job.getUser(), job);
+        } catch (Exception e) {
+           LOGGER.error("Failed to get workspace", e);
+        }
+        runtimeMap.put("workspace", workspace);
+        job.setRuntimeParams(runtimeMap);
+    }
+
+    private String getWorkspace(String user, Job job) throws Exception {
+        String linkisUrl = LinkisURLService.Factory.getLinkisURLService().getDefaultLinkisURL(job);
+        String token = LinkisJobExecutionConfiguration.LINKIS_AUTHOR_USER_TOKEN.getValue(job.getJobProps());
+        String dssUrl = linkisUrl.endsWith("/") ? linkisUrl + "api/rest_j/v1/dss/framework/project/getWorkSpaceStr"
+                : linkisUrl + "/api/rest_j/v1/dss/framework/project/getWorkSpaceStr";
+        HttpGet httpGet = new HttpGet(dssUrl);
+        List<NameValuePair> params = new ArrayList<>();
+        params.add(new BasicNameValuePair("Token-User", user));
+        params.add(new BasicNameValuePair("Token-Code", token));
+        httpGet.addHeader("Token-User", user);
+        httpGet.addHeader("Token-Code", token);
+        CookieStore cookieStore = new BasicCookieStore();
+        CloseableHttpClient httpClient = null;
+        CloseableHttpResponse response = null;
+        HttpClientContext context;
+        String responseContent;
+        try {
+            httpClient = HttpClients.custom().setDefaultCookieStore(cookieStore).build();
+            context = HttpClientContext.create();
+            response = httpClient.execute(httpGet, context);
+            HttpEntity entity = response.getEntity();
+            responseContent = EntityUtils.toString(entity,"utf-8");
+            Gson gson = new Gson();
+            Map resultMap = gson.fromJson(responseContent, Map.class);
+            Object obj = resultMap.get("data");
+            if (obj instanceof Map){
+                if (null != ((Map) obj).get("workspaceStr")){
+                    return ((Map) obj).get("workspaceStr").toString();
+                }else {
+                    return "";
+                }
+            }
+        } finally {
+            IOUtils.closeQuietly(response);
+            IOUtils.closeQuietly(httpClient);
+        }
+        return "";
     }
 
+
     @Override
     protected void fillLinkisJobInfo(LinkisJob linkisJob) {
         linkisJob.setConfiguration(findConfiguration(LinkisJobExecutionConfiguration.NODE_CONF_PREFIX));
-        linkisJob.setVariables(findVariables(LinkisJobExecutionConfiguration.FLOW_VARIABLE_PREFIX));
+        Map<String, Object> variables = findVariables(LinkisJobExecutionConfiguration.FLOW_VARIABLE_PREFIX);
+        //只有工作流参数中没有设置,我们才会去进行替换
+        if(jobProps.containsKey("run_date") && !variables.containsKey("run_date")){
+            variables.put("run_date", jobProps.get("run_date"));
+        }
+        linkisJob.setVariables(variables);
         linkisJob.setSource(getSource());
     }
 
     @Override
-    protected void fillCommonLinkisJobInfo(CommonLinkisJob linkisAppjointJob) {
-        linkisAppjointJob.setJobResourceList(LinkisJobExecutionUtils.getResourceListByJson(jobProps.get("resources")));
+    protected void fillCommonLinkisJobInfo(CommonLinkisJob linkisAppConnJob) {
+        linkisAppConnJob.setJobResourceList(LinkisJobExecutionUtils.getResourceListByJson(jobProps.get("resources")));
 
         String projectResourceName = LinkisJobExecutionConfiguration.PROJECT_PREFIX + "."
                 + jobProps.get(LinkisJobTypeConf.PROJECT_NAME) + LinkisJobExecutionConfiguration.RESOURCES_NAME;
-        linkisAppjointJob.setProjectResourceList(LinkisJobExecutionUtils.getResourceListByJson(jobProps.get(projectResourceName)));
+        linkisAppConnJob.setProjectResourceList(LinkisJobExecutionUtils.getResourceListByJson(jobProps.get(projectResourceName)));
 
-        linkisAppjointJob.setFlowNameAndResources(findFLowNameAndResources());
+        linkisAppConnJob.setFlowNameAndResources(findFLowNameAndResources());
     }
 
 
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/JobBuilder.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/JobBuilder.java
index cd38f70b3b..a206f1781b 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/JobBuilder.java
+++ b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/job/JobBuilder.java
@@ -1,8 +1,7 @@
 /*
  * Copyright 2019 WeBank
- *
  * Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with 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
@@ -17,18 +16,11 @@
 
 package com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.job;
 
-/**
- * Created by peacewong on 2019/11/3.
- */
-public class JobBuilder {
-
-    private static AzkanbanBuilder azkanbanBuilder = new AzkanbanBuilder();
 
+public class JobBuilder {
 
     public static AzkanbanBuilder getAzkanbanBuilder(){
-        return azkanbanBuilder;
+        return new AzkanbanBuilder();
     }
 
-
-
 }
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/log/AzkabanAppjointLog.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/log/AzkabanAppConnLog.java
similarity index 73%
rename from plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/log/AzkabanAppjointLog.java
rename to plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/log/AzkabanAppConnLog.java
index 0d674b0cce..70f3c73152 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/log/AzkabanAppjointLog.java
+++ b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/log/AzkabanAppConnLog.java
@@ -1,8 +1,7 @@
 /*
  * Copyright 2019 WeBank
- *
  * Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with 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
@@ -18,16 +17,14 @@
 package com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.log;
 
 import com.webank.wedatasphere.dss.linkis.node.execution.log.LinkisJobExecutionLog;
-import org.apache.log4j.Logger;
+import org.slf4j.Logger;
 
-/**
- * Created by peacewong on 2019/11/3.
- */
-public class AzkabanAppjointLog extends LinkisJobExecutionLog {
+
+public class AzkabanAppConnLog extends LinkisJobExecutionLog {
 
     private  Logger log;
 
-    public AzkabanAppjointLog(Logger log){
+    public AzkabanAppConnLog(Logger log){
         this.log = log;
     }
 
@@ -35,16 +32,16 @@ public AzkabanAppjointLog(Logger log){
 
     @Override
     public void info(Object message, Throwable t) {
-        log.info(message, t);
+        log.info(message.toString(), t);
     }
 
     @Override
     public void warn(Object message, Throwable t) {
-        log.warn(message, t);
+        log.warn(message.toString(), t);
     }
 
     @Override
     public void error(Object message, Throwable t) {
-        log.error(message, t);
+        log.error(message.toString(), t);
     }
 }
diff --git a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/utils/LinkisJobTypeUtils.java b/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/utils/LinkisJobTypeUtils.java
deleted file mode 100644
index 8da970a262..0000000000
--- a/plugins/azkaban/linkis-jobtype/src/main/java/com/webank/wedatasphere/dss/plugins/azkaban/linkis/jobtype/utils/LinkisJobTypeUtils.java
+++ /dev/null
@@ -1,43 +0,0 @@
-/*
- * Copyright 2019 WeBank
- *
- * Licensed 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 com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.utils;
-
-import com.webank.wedatasphere.dss.linkis.node.execution.WorkflowContext;
-import com.webank.wedatasphere.dss.linkis.node.execution.conf.LinkisJobExecutionConfiguration;
-import com.webank.wedatasphere.dss.plugins.azkaban.linkis.jobtype.conf.LinkisJobTypeConf;
-import org.apache.commons.lang.StringUtils;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * Created by peacewong on 2019/11/3.
- */
-public class LinkisJobTypeUtils {
-
-    public static boolean isSignalNode(String jobType){
-        String[] nodes = LinkisJobTypeConf.SIGNAL_NODES.getValue().split(",");
-        for(String node : nodes){
-            if (node.equalsIgnoreCase(jobType)) {
-                return true;
-            }
-        }
-        return false;
-    }
-
-}
diff --git a/plugins/azkaban/linkis-jobtype/src/main/resources/assembly.xml b/plugins/azkaban/linkis-jobtype/src/main/resources/assembly.xml
index a5d8302db8..998b20debb 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/resources/assembly.xml
+++ b/plugins/azkaban/linkis-jobtype/src/main/resources/assembly.xml
@@ -1,8 +1,7 @@
 <!--
   ~ Copyright 2019 WeBank
-  ~
   ~ Licensed under the Apache License, Version 2.0 (the "License");
-  ~  you may not use this file except in compliance with 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
@@ -59,6 +58,15 @@
             <lineEnding>unix</lineEnding>
         </fileSet>
 
+        <fileSet>
+            <directory>${basedir}/target</directory>
+            <includes>
+                <include>*.jar</include>
+            </includes>
+            <fileMode>0777</fileMode>
+            <outputDirectory>/</outputDirectory>
+            <lineEnding>unix</lineEnding>
+        </fileSet>
         <fileSet>
             <directory>${basedir}/bin</directory>
             <includes>
diff --git a/plugins/azkaban/linkis-jobtype/src/main/resources/plugin.properties b/plugins/azkaban/linkis-jobtype/src/main/resources/plugin.properties
index 810676465a..7389fb22e8 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/resources/plugin.properties
+++ b/plugins/azkaban/linkis-jobtype/src/main/resources/plugin.properties
@@ -1,8 +1,7 @@
 #
 # Copyright 2019 WeBank
-#
 # Licensed under the Apache License, Version 2.0 (the "License");
-#  you may not use this file except in compliance with 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
@@ -15,6 +14,7 @@
 #
 #
 
-wds.linkis.gateway.url=http://127.0.0.1:9001
+wds.linkis.gateway.url.v1=http://127.0.0.1:9001
+wds.linkis.gateway.url.v0=http://127.0.0.1:9001
 wds.linkis.client.flow.author.user.token=WS-AUTH
 wds.linkis.flow.job.creator=scheduler
diff --git a/plugins/azkaban/linkis-jobtype/src/main/resources/private.properties b/plugins/azkaban/linkis-jobtype/src/main/resources/private.properties
index da9c8470f8..c3d0200d8c 100644
--- a/plugins/azkaban/linkis-jobtype/src/main/resources/private.properties
+++ b/plugins/azkaban/linkis-jobtype/src/main/resources/private.properties
@@ -1,8 +1,7 @@
 #
 # Copyright 2019 WeBank
-#
 # Licensed under the Apache License, Version 2.0 (the "License");
-#  you may not use this file except in compliance with 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
diff --git a/dss-common/pom.xml b/plugins/linkis/dss-gateway-support/pom.xml
similarity index 75%
rename from dss-common/pom.xml
rename to plugins/linkis/dss-gateway-support/pom.xml
index 4fe637f11b..260d48eeee 100644
--- a/dss-common/pom.xml
+++ b/plugins/linkis/dss-gateway-support/pom.xml
@@ -1,9 +1,8 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!--
   ~ Copyright 2019 WeBank
-  ~
   ~ Licensed under the Apache License, Version 2.0 (the "License");
-  ~  you may not use this file except in compliance with 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
@@ -19,35 +18,23 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
     <parent>
         <artifactId>dss</artifactId>
         <groupId>com.webank.wedatasphere.dss</groupId>
-        <version>0.9.1</version>
+        <version>1.0.0</version>
     </parent>
-    <artifactId>dss-common</artifactId>
+    <modelVersion>4.0.0</modelVersion>
 
+    <artifactId>dss-gateway-support</artifactId>
     <dependencies>
         <dependency>
             <groupId>com.webank.wedatasphere.linkis</groupId>
-            <artifactId>linkis-common</artifactId>
+            <artifactId>linkis-gateway-server-support</artifactId>
             <version>${linkis.version}</version>
         </dependency>
     </dependencies>
-
-
     <build>
         <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-compiler-plugin</artifactId>
-                <version>3.3</version>
-                <configuration>
-                    <source>1.8</source>
-                    <target>1.8</target>
-                    <encoding>UTF-8</encoding>
-                </configuration>
-            </plugin>
             <plugin>
                 <groupId>org.apache.maven.plugins</groupId>
                 <artifactId>maven-deploy-plugin</artifactId>
@@ -64,4 +51,5 @@
         </plugins>
     </build>
 
+
 </project>
\ No newline at end of file
diff --git a/dss-appjoint-loader/src/main/scala/com/webank/wedatasphere/dss/appjoint/conf/AppJointLoaderConf.scala b/plugins/linkis/dss-gateway-support/src/main/scala/com/webank/wedatasphere/linkis/gateway/parser/DSSGatewayConfiguration.scala
similarity index 54%
rename from dss-appjoint-loader/src/main/scala/com/webank/wedatasphere/dss/appjoint/conf/AppJointLoaderConf.scala
rename to plugins/linkis/dss-gateway-support/src/main/scala/com/webank/wedatasphere/linkis/gateway/parser/DSSGatewayConfiguration.scala
index d20e963904..b5d30e0a99 100644
--- a/dss-appjoint-loader/src/main/scala/com/webank/wedatasphere/dss/appjoint/conf/AppJointLoaderConf.scala
+++ b/plugins/linkis/dss-gateway-support/src/main/scala/com/webank/wedatasphere/linkis/gateway/parser/DSSGatewayConfiguration.scala
@@ -1,8 +1,7 @@
 /*
  * Copyright 2019 WeBank
- *
  * Licensed under the Apache License, Version 2.0 (the "License");
- *  you may not use this file except in compliance with 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
@@ -15,14 +14,19 @@
  *
  */
 
-package com.webank.wedatasphere.dss.appjoint.conf
+package com.webank.wedatasphere.linkis.gateway.parser
 
 import com.webank.wedatasphere.linkis.common.conf.CommonVars
 
-/**
-  * created by cooperyang on 2019/11/9
-  * Description:
-  */
-object AppJointLoaderConf {
-  val CLASS_LOADER_CLASS_NAME = CommonVars("dss.appjoint.loader.classname", "")
+
+object DSSGatewayConfiguration {
+  val DSS_SPRING_NAME = CommonVars("wds.linkis.dss.name", "dss-server")
+
+  val DSS_URL_LABEL_PREFIX = CommonVars("wds.dss.gateway.url.prefix.name", "labels")
+
+  val DSS_URL_ROUTE_LABEL_PREFIX = CommonVars("wds.dss.gateway.url.prefix.name", "labelsRoute")
+
+  val DSS_URL_APPCONNS = CommonVars("wds.dss.gateway.url.appconns", "visualis")
+
+
 }
diff --git a/plugins/linkis/dss-gateway-support/src/main/scala/com/webank/wedatasphere/linkis/gateway/parser/DSSGatewayParser.scala b/plugins/linkis/dss-gateway-support/src/main/scala/com/webank/wedatasphere/linkis/gateway/parser/DSSGatewayParser.scala
new file mode 100644
index 0000000000..16e6c015b9
--- /dev/null
+++ b/plugins/linkis/dss-gateway-support/src/main/scala/com/webank/wedatasphere/linkis/gateway/parser/DSSGatewayParser.scala
@@ -0,0 +1,209 @@
+/*
+ * Copyright 2019 WeBank
+ * Licensed 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 com.webank.wedatasphere.linkis.gateway.parser
+
+import java.util
+
+import com.webank.wedatasphere.linkis.common.ServiceInstance
+import com.webank.wedatasphere.linkis.gateway.exception.TooManyServiceException
+import com.webank.wedatasphere.linkis.gateway.http.GatewayContext
+import com.webank.wedatasphere.linkis.gateway.springcloud.SpringCloudGatewayConfiguration.{API_URL_PREFIX, normalPath}
+import com.webank.wedatasphere.linkis.manager.label.builder.factory.LabelBuilderFactoryContext
+import com.webank.wedatasphere.linkis.manager.label.entity.Label
+import com.webank.wedatasphere.linkis.manager.label.entity.route.RouteLabel
+import com.webank.wedatasphere.linkis.protocol.constants.TaskConstant
+import com.webank.wedatasphere.linkis.rpc.sender.SpringCloudFeignConfigurationCache
+import com.webank.wedatasphere.linkis.server.BDPJettyServerHelper
+import org.springframework.stereotype.Component
+
+import scala.collection.JavaConversions._
+
+
+@Component
+class DSSGatewayParser extends AbstractGatewayParser {
+
+  val appConns = DSSGatewayConfiguration.DSS_URL_APPCONNS.getValue.split(",")
+
+  override def shouldContainRequestBody(gatewayContext: GatewayContext): Boolean = {
+    var contentType = gatewayContext.getRequest.getHeaders.get("Content-Type")
+    if(null == contentType) {
+      contentType = gatewayContext.getRequest.getHeaders.get("content-type")
+    }
+
+    if(contentType != null && contentType.nonEmpty
+          && contentType(0).contains("form-data")){
+      logger.info("DSS gateway get request type is form-data")
+      return false
+    }
+
+    gatewayContext.getRequest.getRequestURI match {
+      case DSSGatewayParser.DSS_URL_DEFAULT_REGEX(_, _) => true
+      case DSSGatewayParser.DSS_URL_REGEX(_, _,_) => true
+      case DSSGatewayParser.APPCONN_URL_DEFAULT_REGEX(_,appconn, _) if appConns.contains(appconn) => true
+      case _ => false
+    }
+  }
+
+  override def parse(gatewayContext: GatewayContext): Unit = gatewayContext.getRequest.getRequestURI match {
+
+    case DSSGatewayParser.DSS_URL_REGEX(version, firstName, secondName) =>
+      if (sendResponseWhenNotMatchVersion(gatewayContext, version)) return
+      var tmpServerName = "dss-" + firstName + "-" + secondName + "-server"
+      tmpServerName = getServiceNameFromLabel(gatewayContext, tmpServerName)
+      val serviceName: Option[String] = findCommonService("dss/" + firstName + "/" + secondName, tmpServerName)
+      if (serviceName.isDefined) {
+        gatewayContext.getGatewayRoute.setServiceInstance(ServiceInstance(serviceName.get, null))
+      } else {
+        logger.info("Now set default serviceInstance name " + DSSGatewayConfiguration.DSS_SPRING_NAME.getValue + "," + gatewayContext.getRequest.getRequestURI)
+        gatewayContext.getGatewayRoute.setServiceInstance(ServiceInstance(DSSGatewayConfiguration.DSS_SPRING_NAME.getValue, null))
+      }
+    case DSSGatewayParser.DSS_URL_DEFAULT_REGEX(version, firstName) =>
+      if (sendResponseWhenNotMatchVersion(gatewayContext, version)) return
+      var tmpServerName = "dss-" + firstName + "-server"
+      tmpServerName = getServiceNameFromLabel(gatewayContext, tmpServerName)
+      val serviceName: Option[String] = findCommonService("dss/" + firstName, tmpServerName)
+      if (serviceName.isDefined) {
+        gatewayContext.getGatewayRoute.setServiceInstance(ServiceInstance(serviceName.get, null))
+      } else {
+        logger.info("Now set default serviceInstance name " + DSSGatewayConfiguration.DSS_SPRING_NAME.getValue + "," + gatewayContext.getRequest.getRequestURI)
+        gatewayContext.getGatewayRoute.setServiceInstance(ServiceInstance(DSSGatewayConfiguration.DSS_SPRING_NAME.getValue, null))
+      }
+    case DSSGatewayParser.APPCONN_URL_DEFAULT_REGEX(version, serverName, _) if appConns.contains(serverName) =>
+      if (sendResponseWhenNotMatchVersion(gatewayContext, version)) return
+      var tmpServerName = serverName
+      tmpServerName = getServiceNameFromLabel(gatewayContext, tmpServerName)
+      val serviceName: Option[String] = findCommonService(tmpServerName, tmpServerName)
+      if (serviceName.isDefined) {
+        gatewayContext.getGatewayRoute.setServiceInstance(ServiceInstance(serviceName.get, null))
+      } else {
+        logger.info("Now set default serviceInstance name " + DSSGatewayConfiguration.DSS_SPRING_NAME.getValue + "," + gatewayContext.getRequest.getRequestURI)
+        gatewayContext.getGatewayRoute.setServiceInstance(ServiceInstance(DSSGatewayConfiguration.DSS_SPRING_NAME.getValue, null))
+      }
+    case _ =>
+  }
+
+  private def getServiceNameFromLabel(gatewayContext: GatewayContext, tmpServiceName: String): String = {
+    var requestUrlLabels = gatewayContext.getRequest.getQueryParams.getOrDefault(DSSGatewayConfiguration.DSS_URL_LABEL_PREFIX.getValue, null)
+    if(requestUrlLabels == null) requestUrlLabels = gatewayContext.getRequest.getQueryParams.getOrDefault(DSSGatewayConfiguration.DSS_URL_ROUTE_LABEL_PREFIX.getValue,null)
+    logger.info("Get ServiceName From  Label and method is "+ gatewayContext.getRequest.getMethod.toString+",and urlLabels is "+requestUrlLabels)
+    if (requestUrlLabels == null && gatewayContext.getRequest.getMethod.equalsIgnoreCase("post")) {
+      val requestBody = Option(gatewayContext.getRequest.getRequestBody)
+      val routeLabelList = new util.ArrayList[RouteLabel]()
+
+      requestBody match {
+          //todo form-data resolve
+        case Some(body) =>
+          val labelBuilderFactory = LabelBuilderFactoryContext.getLabelBuilderFactory
+          val json = BDPJettyServerHelper.gson.fromJson(body, classOf[java.util.Map[String, Object]])
+          val labels: util.List[Label[_]] = json.get(TaskConstant.LABELS) match {
+            case map: util.Map[String, Object] => labelBuilderFactory.getLabels(map)
+            case map: util.Map[String, Any] => labelBuilderFactory.getLabels(map.asInstanceOf)
+            case _ => new util.ArrayList[Label[_]]()
+          }
+          labels.filter(label => label.isInstanceOf[RouteLabel]).foreach(label => {
+            routeLabelList.add(label.asInstanceOf[RouteLabel])
+          })
+
+        case _ => null
+      }
+      val labelNameList = routeLabelList.map(routeLabel => routeLabel.getStringValue).toList
+      if(labelNameList != null && labelNameList.size>0) {
+        genServiceNameByDSSLabel(labelNameList, tmpServiceName)
+      }else if(null != requestUrlLabels){
+        genServiceNameByDSSLabel(requestUrlLabels.toList, tmpServiceName)
+      } else tmpServiceName
+
+    } else {
+      if(requestUrlLabels != null) {
+        genServiceNameByDSSLabel(requestUrlLabels.toList, tmpServiceName)
+      }else tmpServiceName
+    }
+  }
+
+  private def genServiceNameByDSSLabel(labelList: List[String], tmpServiceName: String): String = {
+    var resultName = tmpServiceName
+    if (null != labelList && labelList.size > 0) {
+      val labelNameList = labelList(0).replace(" ", "").split(",").toList
+      if (labelNameList.size > 0) {
+        if (labelNameList.find(name => name.equalsIgnoreCase("dev")).isDefined) {
+          resultName = tmpServiceName + "-dev"
+        } else if (labelNameList.find(name => name.equalsIgnoreCase("prod")).isDefined) {
+          resultName = tmpServiceName + "-prod"
+        } else if (labelNameList.find(name => name.equalsIgnoreCase("test")).isDefined){
+          resultName = tmpServiceName + "-test"
+        }else{
+          resultName = tmpServiceName
+        }
+      }
+    }
+    resultName
+  }
+
+
+  private def findCommonService(parsedServiceId: String, tmpServerName: String) = findService(parsedServiceId, tmpServerName, services => {
+    val errorMsg = new TooManyServiceException(s"Cannot find a correct serviceId for parsedServiceId $parsedServiceId, service list is: " + services)
+    warn("", errorMsg)
+    throw errorMsg
+  })
+
+  protected def findService(parsedServiceId: String, tmpServerName: String, tooManyDeal: List[String] => Option[String]): Option[String] = {
+    val findIt: (String => Boolean) => Option[String] = op => {
+      val services = SpringCloudFeignConfigurationCache.getDiscoveryClient
+        .getServices.filter(op).toList
+      if (services.length == 1) Some(services.head)
+      else if (services.length > 1) tooManyDeal(services)
+      else None
+    }
+    //通过匹配到最多的url中的path进行路由,如/dss/framework/workspace/ 会匹配到 dss-framework-workspace-server 而不是 dss-server
+    // 如果产生了相等的情况，则按照短的service名字为准 比如/dss/getProject,
+    // 我们可能会匹配到dss-server以及 dss-framework-workspace-server,则选择短名称的dss-server
+    val findMostCorrect: (String => (String, Int)) => Option[String] = { op => {
+      val serviceMap = SpringCloudFeignConfigurationCache.getDiscoveryClient
+        .getServices.map(op).toMap
+      var count = 0
+      var retService: Option[String] = None
+      serviceMap.foreach {
+        case (k, v) => if (v > count) {
+          count = v
+          retService = Some(k)
+        } else if (retService.isDefined && v == count && k.length < retService.get.length) {
+          retService = Some(k)
+        }
+      }
+      retService
+    }
+    }
+    val lowerServiceId = parsedServiceId.toLowerCase
+    val serverName = tmpServerName.toLowerCase
+    //findIt(_.toLowerCase == lowerServiceId).orElse(findIt(_.toLowerCase.contains(lowerServiceId)))
+    findIt(_.toLowerCase == serverName).orElse(findMostCorrect(service => {
+      (service, lowerServiceId.split("/").count(word => service.contains(word)))
+    }))
+  }
+
+
+}
+
+object DSSGatewayParser {
+  val DSS_HEADER = normalPath(API_URL_PREFIX) + "rest_[a-zA-Z][a-zA-Z_0-9]*/(v\\d+)/dss/"
+  val DSS_URL_REGEX = (DSS_HEADER + "([^/]+)/" + "([^/]+)/.+").r
+  val DSS_URL_DEFAULT_REGEX = (DSS_HEADER + "([^/]+).+").r
+
+  val APPCONN_HEADER = normalPath(API_URL_PREFIX) + "rest_[a-zA-Z][a-zA-Z_0-9]*/(v\\d+)/([^/]+)/"
+  val APPCONN_URL_DEFAULT_REGEX = (APPCONN_HEADER + "([^/]+).+").r
+
+}
diff --git a/plugins/linkis/dss-gateway-support/src/main/scala/com/webank/wedatasphere/linkis/gateway/parser/DSSRouteLabelParser.scala b/plugins/linkis/dss-gateway-support/src/main/scala/com/webank/wedatasphere/linkis/gateway/parser/DSSRouteLabelParser.scala
new file mode 100644
index 0000000000..59e4fe40d1
--- /dev/null
+++ b/plugins/linkis/dss-gateway-support/src/main/scala/com/webank/wedatasphere/linkis/gateway/parser/DSSRouteLabelParser.scala
@@ -0,0 +1,38 @@
+/*
+ * Copyright 2019 WeBank
+ * Licensed 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 com.webank.wedatasphere.linkis.gateway.parser
+
+import java.util
+
+import com.webank.wedatasphere.linkis.gateway.http.GatewayContext
+import com.webank.wedatasphere.linkis.gateway.ujes.route.label.RouteLabelParser
+import com.webank.wedatasphere.linkis.manager.label.builder.factory.LabelBuilderFactoryContext
+import com.webank.wedatasphere.linkis.manager.label.entity.Label
+import com.webank.wedatasphere.linkis.manager.label.entity.route.RouteLabel
+import com.webank.wedatasphere.linkis.protocol.constants.TaskConstant
+import com.webank.wedatasphere.linkis.server.BDPJettyServerHelper
+import org.springframework.stereotype.Component
+
+import scala.collection.JavaConversions._
+
+
+@Component
+class DSSRouteLabelParser  extends RouteLabelParser{
+  override def parse(gatewayContext: GatewayContext): util.List[RouteLabel] = {
+    new util.ArrayList[RouteLabel]()
+  }
+}