[Version Feature] Collection of features support in version 0.2.0

.gitignore

@@ -15,4 +15,5 @@ streamis-jobmanager/streamis-projectmanager-server/target
 streamis-project/streamis-project-common/target
 streamis-project/streamis-project-server/target
 
-streamis-server/target
+streamis-server/target
+streamis-appconn/target

assembly/pom.xml

@@ -20,7 +20,7 @@
     <parent>
         <artifactId>streamis</artifactId>
         <groupId>com.webank.wedatasphere.streamis</groupId>
-        <version>0.1.0</version>
+        <version>0.2.0</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 

db/streamis_ddl.sql

@@ -2,51 +2,47 @@
 SET NAMES utf8mb4;
 SET FOREIGN_KEY_CHECKS = 0;
 
--- ----------------------------
--- Table structure for linkis_stream_configuration_config_key
--- ----------------------------
-DROP TABLE IF EXISTS `linkis_stream_configuration_config_key`;
-CREATE TABLE `linkis_stream_configuration_config_key`  (
-  `id` bigint(20) NOT NULL,
-  `key` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  `name` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  `description` varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  `default_value` varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  `validate_type` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  `validate_range` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  `is_hidden` tinyint(1) NULL DEFAULT NULL,
-  `is_advanced` tinyint(1) NULL DEFAULT NULL,
-  `level` tinyint(1) NULL DEFAULT NULL,
-  `treename` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  `type` int(10) NULL DEFAULT NULL,
-  `sort` int(10) NULL DEFAULT NULL,
-  `status` tinyint(10) NULL DEFAULT NULL COMMENT '1 custom , 2 selected ',
-  PRIMARY KEY (`id`) USING BTREE,
-  UNIQUE INDEX `key_index`(`key`) USING BTREE
-) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '配置信息' ROW_FORMAT = Compact;
-
-
--- ----------------------------
--- Table structure for linkis_stream_configuration_config_value
--- ----------------------------
-DROP TABLE IF EXISTS `linkis_stream_configuration_config_value`;
-CREATE TABLE `linkis_stream_configuration_config_value`  (
-  `id` bigint(20) NOT NULL,
-  `configkey_id` bigint(20) NULL DEFAULT NULL,
-  `config_value` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  `type` int(10) NULL DEFAULT NULL,
-  `job_id` bigint(20) NULL DEFAULT NULL,
-  `job_name` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  `config_key` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
-  PRIMARY KEY (`id`) USING BTREE,
-  INDEX `key`(`config_key`) USING BTREE,
-  INDEX `keyid`(`configkey_id`) USING BTREE
-) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '配置信息' ROW_FORMAT = Compact;
-
--- ----------------------------
--- Records of linkis_stream_configuration_config_value
--- ----------------------------
+--
+-- Table structure for table `linkis_stream_job_config_def`
+--
 
+DROP TABLE IF EXISTS `linkis_stream_job_config_def`;
+CREATE TABLE `linkis_stream_job_config_def` (
+  `id` bigint(20) NOT NULL AUTO_INCREMENT,
+  `key` varchar(100) COLLATE utf8_bin NOT NULL,
+  `name` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT 'Equals option',
+  `type` varchar(50) COLLATE utf8_bin NOT NULL DEFAULT 'NONE' COMMENT 'def type, NONE: 0, INPUT: 1, SELECT: 2',
+  `sort` int(10) DEFAULT '0' COMMENT 'In order to sort the configurations that have the same level',
+  `description` varchar(200) COLLATE utf8_bin DEFAULT NULL COMMENT 'Description of configuration',
+  `validate_type` varchar(50) COLLATE utf8_bin DEFAULT NULL COMMENT 'Method the validate the configuration',
+  `validate_rule` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT 'Value of validation rule',
+  `style` varchar(200) COLLATE utf8_bin DEFAULT '' COMMENT 'Display style',
+  `visiable` tinyint(1) NOT NULL DEFAULT '1' COMMENT '0: hidden, 1: display',
+  `level` tinyint(1) NOT NULL DEFAULT '1' COMMENT '0: root, 1: leaf',
+  `unit` varchar(25) COLLATE utf8_bin DEFAULT NULL COMMENT 'Unit symbol',
+  `default_value` varchar(200) COLLATE utf8_bin DEFAULT NULL COMMENT 'Default value',
+  `ref_values` varchar(200) COLLATE utf8_bin DEFAULT '',
+  `parent_ref` bigint(20) DEFAULT NULL COMMENT 'Parent key of configuration def',
+  `required` tinyint(1) NOT NULL DEFAULT '0' COMMENT 'If the value of configuration is necessary',
+  `is_temp` tinyint(1) DEFAULT '0' COMMENT 'Temp configuration',
+  PRIMARY KEY (`id`),
+  UNIQUE KEY `config_def_key` (`key`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
+
+--
+-- Table structure for table `linkis_stream_job_config`
+--
+
+DROP TABLE IF EXISTS `linkis_stream_job_config`;
+CREATE TABLE `linkis_stream_job_config` (
+  `job_id` bigint(20) NOT NULL,
+  `job_name` varchar(200) COLLATE utf8_bin NOT NULL COMMENT 'Just store the job name',
+  `key` varchar(100) COLLATE utf8_bin NOT NULL,
+  `value` varchar(500) COLLATE utf8_bin NOT NULL,
+  `ref_def_id` bigint(20) DEFAULT NULL COMMENT 'Refer to id in config_def table',
+  PRIMARY KEY (`job_id`,`key`),
+  KEY `config_def_id` (`ref_def_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
 
 -- ----------------------------
 -- Table structure for linkis_stream_job_alarm_send_history
@@ -129,8 +125,8 @@ DROP TABLE IF EXISTS `linkis_stream_job`;
 
 CREATE TABLE `linkis_stream_job` (
   `id` bigint(20) NOT NULL AUTO_INCREMENT,
-  `project_name` varchar(50) DEFAULT NULL,
-  `name` varchar(50) DEFAULT NULL,
+  `project_name` varchar(100) DEFAULT NULL,
+  `name` varchar(200) DEFAULT NULL,
   `status` tinyint(1) DEFAULT '0' COMMENT '1:已完成 ，2:等待重启 ，3:告警 ，4:慢任务 ，5:运行中 ，6:失败任务',
   `create_by` varchar(50) DEFAULT NULL,
   `create_time` datetime DEFAULT NULL,
@@ -139,7 +135,8 @@ CREATE TABLE `linkis_stream_job` (
   `job_type` varchar(30) DEFAULT NULL COMMENT '目前只支持flink.sql、flink.jar',
   `submit_user` varchar(100) DEFAULT NULL,
   `workspace_name` varchar(50) DEFAULT NULL,
-  PRIMARY KEY (`id`) USING BTREE
+  PRIMARY KEY (`id`) USING BTREE,
+  UNIQUE KEY(`project_name`, `name`)
 ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='作业表';
 
 /*Table structure for table `linkis_stream_job_version` */
@@ -155,7 +152,8 @@ CREATE TABLE `linkis_stream_job_version` (
   `comment` varchar(255) DEFAULT NULL,
   `create_time` datetime DEFAULT NULL,
   `create_by` varchar(32) DEFAULT NULL,
-  PRIMARY KEY (`id`) USING BTREE
+  PRIMARY KEY (`id`) USING BTREE,
+  UNIQUE KEY(`job_id`, `version`)
 ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='作业表';
 
 /*Table structure for table `linkis_stream_job_version_files` */
@@ -182,7 +180,7 @@ DROP TABLE IF EXISTS `linkis_stream_project`;
 CREATE TABLE `linkis_stream_project` (
   `id` bigint(20) NOT NULL AUTO_INCREMENT,
   `workspace_id` bigint(20) DEFAULT NULL,
-  `name` varchar(50) DEFAULT NULL,
+  `name` varchar(100) DEFAULT NULL,
   `create_by` varchar(50) DEFAULT NULL,
   PRIMARY KEY (`id`) USING BTREE
 ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='项目表';
@@ -211,14 +209,14 @@ DROP TABLE IF EXISTS `linkis_stream_task`;
 CREATE TABLE `linkis_stream_task` (
   `id` int(11) NOT NULL AUTO_INCREMENT,
   `job_version_id` bigint(20) NOT NULL,
-  `job_id` varchar(50) DEFAULT NULL,
+  `job_id` varchar(200) DEFAULT NULL,
   `version` varchar(50) DEFAULT NULL,
   `status` int(3) DEFAULT NULL,
   `start_time` datetime DEFAULT NULL,
   `last_update_time` datetime DEFAULT NULL,
   `err_desc` varchar(10240) DEFAULT NULL,
   `submit_user` varchar(50) DEFAULT NULL,
-  `linkis_job_id` varchar(50) DEFAULT NULL,
+  `linkis_job_id` varchar(200) DEFAULT NULL,
   `linkis_job_info` mediumtext,
   PRIMARY KEY (`id`) USING BTREE
 ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 ROW_FORMAT=COMPACT COMMENT='任务表';
@@ -239,4 +237,20 @@ CREATE TABLE `linkis_stream_alert_record` (
   PRIMARY KEY (`id`)
 ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
 
+DROP TABLE IF EXISTS `linkis_stream_project_privilege`;
+
+CREATE TABLE `linkis_stream_project_privilege` (
+  `id` bigint(20) NOT NULL AUTO_INCREMENT,
+  `project_id` bigint(20) NOT NULL,
+  `user_name` varchar(100) NOT NULL,
+  `privilege` tinyint(1) DEFAULT '0' NOT NULL COMMENT '1:发布权限 ，2:编辑权限 ，3:查看权限',
+  PRIMARY KEY (`id`) USING BTREE
+) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='项目权限表';
+
+
+ALTER TABLE `linkis_stream_project` ADD create_time datetime DEFAULT NULL;
+ALTER TABLE `linkis_stream_project` ADD last_update_by varchar(50) DEFAULT NULL;
+ALTER TABLE `linkis_stream_project` ADD last_update_time datetime DEFAULT NULL;
+ALTER TABLE `linkis_stream_project` ADD is_deleted tinyint unsigned DEFAULT 0;
+
 SET FOREIGN_KEY_CHECKS = 1;

db/streamis_dml.sql

@@ -1,22 +1,25 @@
 -- ----------------------------
--- Records of linkis_stream_configuration_config_key
+-- Records of linkis_stream_job_config_def
 -- ----------------------------
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (1, 'wds.linkis.flink.resource', '资源配置', '资源配置', NULL, 'None', NULL, 0, 0, 1, '资源配置', 1, 0, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (2, 'wds.linkis.flink.taskmanager.num', 'Task Managers数量', 'Task Managers数量', '4', 'Regex', '^(?:[1-9]\\d?|[1234]\\d{2}|128)$', 0, 0, 2, '资源配置', 1, 1, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (3, 'wds.linkis.flink.jobmanager.memory', 'JobManager Memory', 'JobManager Memory', '1.5', 'Regex', '^([1-9]\\d{0,2}|1000)(G|g)$', 0, 0, 2, '资源配置', 1, 2, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (4, 'wds.linkis.flink.taskmanager.memory', 'TaskManager Memory', 'TaskManager Memory', '1.5', 'Regex', '^([1-9]\\d{0,2}|1000)(G|g)$', 0, 0, 2, '资源配置', 1, 3, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (5, 'wds.linkis.flink.jobmanager.cpus', 'JobManager CPUs', 'JobManager CPUs', '1', 'Regex', '^(?:[1-9]\\d?|[1234]\\d{2}|128)$', 0, 0, 2, '资源配置', 1, 4, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (6, 'wds.linkis.flink.taskManager.cpus', 'TaskManager CPUs', 'TaskManager CPUs', '1', 'Regex', '^(?:[1-9]\\d?|[1234]\\d{2}|128)$', 0, 0, 2, '资源配置', 1, 5, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (7, 'wds.linkis.flink.custom', '自定义参数', '自定义参数', NULL, 'None', NULL, 0, 0, 1, '自定义参数', 2, 0, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (8, 'wds.linkis.flink.produce', '生产配置', '生产配置', NULL, 'None', NULL, 0, 0, 1, '生产配置', 3, 0, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (9, 'wds.linkis.flink.checkpoint.interval', 'Checkpoint间隔', 'Checkpoint间隔', NULL, NULL, NULL, 0, 0, 2, '生产配置', 3, 1, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (10, 'wds.linkis.flink.reboot.strategy', '重启策略', '重启策略', '不重启,基于Checkpoint自动重启,无Checkpoint不重启', 'None', NULL, 0, 0, 2, '重启策略', 3, 2, 2);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (11, 'wds.linkis.flink.alert', '告警设置', '告警设置', NULL, 'None', NULL, 0, 0, 1, '告警设置', 4, 0, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (12, 'wds.linkis.flink.alert.rule', '告警规则', '告警规则', '任务日志中出现ERROR/EXCEPTION,任务核心指标出现异常', 'None', NULL, 0, 0, 2, '告警规则', 4, 1, 2);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (13, 'wds.linkis.flink.alert.user', '告警用户', '告警用户', NULL, NULL, NULL, 0, 0, 2, '告警用户', 4, 3, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (14, 'wds.linkis.flink.alert.leve', '告警级别', '告警级别', 'CLEARED,INDETERMINATE,WARNING,MINOR,MAJOR,CRITICAL', 'None', NULL, 0, 0, 2, '告警级别', 4, 2, 2);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (15, 'wds.linkis.flink.alert.failure.level', '失败时告警级别', '失败时告警级别', 'CLEARED,INDETERMINATE,WARNING,MINOR,MAJOR,CRITICAL', 'None', NULL, 0, 0, 2, '失败时告警级别', 4, 4, 2);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (16, 'wds.linkis.flink.alert.failure.user', '失败时告警用户', '失败时告警用户', NULL, 'None', NULL, 0, 0, 2, '失败时告警用户', 4, 5, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (17, 'wds.linkis.flink.authority', '权限设置', '权限设置', NULL, 'None', NULL, 0, 0, 1, '权限设置', 5, 0, 1);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (18, 'wds.linkis.flink.authority.author', '授权模式', '授权模式', '私密,指定全员可见,指定人员可见', 'None', NULL, 0, 0, 2, '授权模式', 5, 1, 2);
-INSERT INTO `linkis_stream_configuration_config_key` VALUES (19, 'wds.linkis.flink.authority.visible', '可见人员', '可见人员', NULL, 'None', NULL, 0, 0, 2, '可见人员', 5, 2, 1);
+
+INSERT INTO `linkis_stream_job_config_def` VALUES (1,'wds.linkis.flink.resource','资源配置','NONE',0,'资源配置','None',NULL,'',1,0,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (2,'wds.linkis.flink.app.parallelism','Parallelism并行度','NUMBER',0,'Parallelism并行度','Regex','^([1-9]\\d{0,1}|100)$','',1,1,NULL,'4','',1,1,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (3,'wds.linkis.flink.jobmanager.memory','JobManager Memory (M)','NUMBER',0,'JobManager Memory (M)','Regex','^([1-9]\\d{0,4}|100000)$','',1,1,'M','1024','',1,1,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (4,'wds.linkis.flink.taskmanager.memory','TaskManager Memory (M)','NUMBER',0,'JobManager Memory (M)','Regex','^([1-9]\\d{0,4}|100000)$','',1,1,'M','4096','',1,1,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (5,'wds.linkis.flink.taskmanager.numberOfTaskSlots','TaskManager Slot数量','NUMBER',0,'TaskManager Slot数量','Regex','^([1-9]\\d{0,1}|100)$','',1,1,NULL,'2','',1,1,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (6,'wds.linkis.flink.taskmanager.cpus','TaskManager CPUs','NUMBER',0,'TaskManager CPUs','Regex','^([1-9]\\d{0,1}|100)$','',1,1,NULL,'2','',1,1,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (7,'wds.linkis.flink.custom','Flink参数','NONE',0,'Flink自定义参数','None',NULL,'',1,0,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (8,'wds.linkis.flink.produce','生产配置','NONE',0,'生产配置','None',NULL,'',1,0,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (9,'wds.linkis.flink.checkpoint.switch','Checkpoint开关','SELECT',0,'Checkpoint开关',NULL,NULL,'',1,1,'','OFF','ON,OFF',8,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (10,'wds.linkis.flink.savepoint.path','快照(Savepoint)文件位置【仅需恢复任务时指定】','INPUT',4,'快照(Savepoint)文件位置','None',NULL,'',1,1,NULL,NULL,'',8,0,1);
+INSERT INTO `linkis_stream_job_config_def` VALUES (11,'wds.linkis.flink.alert','告警设置','NONE',0,'告警设置','None',NULL,'',1,1,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (12,'wds.linkis.flink.alert.rule','告警规则','NONE',0,'告警规则','None',NULL,'',1,1,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (13,'wds.linkis.flink.alert.user','告警用户','NONE',0,'告警用户',NULL,NULL,'',1,1,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (14,'wds.linkis.flink.alert.level','告警级别','NONE',0,'告警级别','None',NULL,'',1,1,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (15,'wds.linkis.flink.alert.failure.level','失败时告警级别','NONE',0,'失败时告警级别','None',NULL,'',1,1,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (16,'wds.linkis.flink.alert.failure.user','失败时告警用户','NONE',0,'失败时告警用户','None',NULL,'',1,1,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (32,'wds.linkis.flink.authority','权限设置','NONE',0,'权限设置','None',NULL,'',1,0,NULL,NULL,'',NULL,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (33,'wds.linkis.flink.authority.visible','可见人员','INPUT',0,'可见人员','None',NULL,'',1,1,NULL,NULL,'',32,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (34,'wds.linkis.rm.yarnqueue','使用Yarn队列','INPUT',0,'使用Yarn队列','None',NULL,'',1,1,NULL,NULL,'',1,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (35,'wds.linkis.flink.app.fail-restart.switch','作业失败自动拉起开关','SELECT',1,'作业失败自动拉起开关','None',NULL,'',1,1,NULL,'OFF','ON,OFF',8,0,0);
+INSERT INTO `linkis_stream_job_config_def` VALUES (36,'wds.linkis.flink.app.start-auto-restore.switch','作业启动状态自恢复','SELECT',2,'作业启动状态自恢复','None',NULL,'',1,1,NULL,'ON','ON,OFF',8,0,0);

pom.xml

@@ -21,7 +21,7 @@
 
     <groupId>com.webank.wedatasphere.streamis</groupId>
     <artifactId>streamis</artifactId>
-    <version>0.1.0</version>
+    <version>0.2.0</version>
     <packaging>pom</packaging>
 
     <name>Streamis Project Parent POM</name>
@@ -38,14 +38,16 @@
 
     <modules>
         <module>streamis-jobmanager</module>
-        <module>streamis-server</module>
         <module>streamis-project</module>
+        <module>streamis-server</module>
         <module>assembly</module>
+        <module>streamis-appconn</module>
     </modules>
 
     <properties>
-        <linkis.version>1.0.3</linkis.version>
-        <streamis.version>0.1.0</streamis.version>
+        <linkis.version>1.1.1</linkis.version>
+        <dss.version>1.1.0</dss.version>
+        <streamis.version>0.2.0</streamis.version>
         <scala.version>2.11.12</scala.version>
         <jdk.compile.version>1.8</jdk.compile.version>
         <maven.version>3.3.3</maven.version>
@@ -67,8 +69,9 @@
         <jersey-bean-validation.version>2.21</jersey-bean-validation.version>
         <aspectj.version>1.9.5</aspectj.version>
         <xstream.version>1.4.19</xstream.version>
-        <jobmanager.version>0.1.0</jobmanager.version>
+        <jobmanager.version>0.2.0</jobmanager.version>
         <mysql.connector.version>5.1.47</mysql.connector.version>
+        <validation.api.version>2.0.1.Final</validation.api.version>
     </properties>
 
 
@@ -105,6 +108,12 @@
                 <artifactId>linkis-mybatis</artifactId>
                 <version>${linkis.version}</version>
             </dependency>
+            <!--scheduler module-->
+            <dependency>
+                <groupId>org.apache.linkis</groupId>
+                <artifactId>linkis-scheduler</artifactId>
+                <version>${linkis.version}</version>
+            </dependency>
             <dependency>
                 <groupId>org.apache.linkis</groupId>
                 <artifactId>linkis-module</artifactId>
@@ -152,6 +161,11 @@
                 <groupId>com.thoughtworks.xstream</groupId>
                 <version>${xstream.version}</version>
             </dependency>
+            <dependency>
+                <groupId>javax.validation</groupId>
+                <artifactId>validation-api</artifactId>
+                <version>${validation.api.version}</version>
+            </dependency>
         </dependencies>
     </dependencyManagement>