Skip to content

Commit 813f4f7

Browse files
author
kaviarpan
committed
Merge branch 'dev-0.2.0' of github.com:WeDataSphere/Streamis into dev-0.2.0
2 parents a62d78b + 37e3e8a commit 813f4f7

File tree

93 files changed

+2061
-1601
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

93 files changed

+2061
-1601
lines changed

‎.gitignore‎

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,4 +15,9 @@ streamis-jobmanager/streamis-projectmanager-server/target
1515
streamis-project/streamis-project-common/target
1616
streamis-project/streamis-project-server/target
1717

18-
streamis-server/target
18+
streamis-server/target
19+
streamis-appconn/target
20+
/logs/streamis-server.log
21+
/logs/linkis.log
22+
/test/target
23+
/test/src

‎conf/config.sh‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,6 @@ GATEWAY_PORT=9001
4040
STREAMIS_SERVER_INSTALL_IP=127.0.0.1
4141
STREAMIS_SERVER_INSTALL_PORT=9400
4242

43-
STREAMIS_VERSION=0.1.0
43+
STREAMIS_VERSION=0.2.0
4444

4545
STREAMIS_FILE_NAME="STREAMIS-$STREAMIS_VERSION"

‎db/streamis_ddl.sql‎

Lines changed: 45 additions & 44 deletions
Original file line numberDiff line numberDiff line change
@@ -2,51 +2,47 @@
22
SET NAMES utf8mb4;
33
SET FOREIGN_KEY_CHECKS = 0;
44

5-
-- ----------------------------
6-
-- Table structure for linkis_stream_configuration_config_key
7-
-- ----------------------------
8-
DROP TABLE IF EXISTS `linkis_stream_configuration_config_key`;
9-
CREATE TABLE `linkis_stream_configuration_config_key` (
10-
`id` bigint(20) NOT NULL,
11-
`key` varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
12-
`name` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
13-
`description` varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
14-
`default_value` varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
15-
`validate_type` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
16-
`validate_range` varchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
17-
`is_hidden` tinyint(1) NULL DEFAULT NULL,
18-
`is_advanced` tinyint(1) NULL DEFAULT NULL,
19-
`level` tinyint(1) NULL DEFAULT NULL,
20-
`treename` varchar(20) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
21-
`type` int(10) NULL DEFAULT NULL,
22-
`sort` int(10) NULL DEFAULT NULL,
23-
`status` tinyint(10) NULL DEFAULT NULL COMMENT '1 custom , 2 selected ',
24-
PRIMARY KEY (`id`) USING BTREE,
25-
UNIQUE INDEX `key_index`(`key`) USING BTREE
26-
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '配置信息' ROW_FORMAT = Compact;
27-
5+
--
6+
-- Table structure for table `linkis_stream_job_config_def`
7+
--
288

29-
-- ----------------------------
30-
-- Table structure for linkis_stream_configuration_config_value
31-
-- ----------------------------
32-
DROP TABLE IF EXISTS `linkis_stream_configuration_config_value`;
33-
CREATE TABLE `linkis_stream_configuration_config_value` (
9+
DROP TABLE IF EXISTS `linkis_stream_job_config_def`;
10+
CREATE TABLE `linkis_stream_job_config_def` (
3411
`id` bigint(20) NOT NULL AUTO_INCREMENT,
35-
`configkey_id` bigint(20) NULL DEFAULT NULL,
36-
`config_value` varchar(500) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
37-
`type` int(10) NULL DEFAULT NULL,
38-
`job_id` bigint(20) NULL DEFAULT NULL,
39-
`job_name` varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
40-
`config_key` varchar(200) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT NULL,
41-
PRIMARY KEY (`id`) USING BTREE,
42-
INDEX `key`(`config_key`) USING BTREE,
43-
INDEX `keyid`(`configkey_id`) USING BTREE
44-
) ENGINE = InnoDB CHARACTER SET = utf8 COLLATE = utf8_general_ci COMMENT = '配置信息' ROW_FORMAT = Compact;
45-
46-
-- ----------------------------
47-
-- Records of linkis_stream_configuration_config_value
48-
-- ----------------------------
49-
12+
`key` varchar(100) COLLATE utf8_bin NOT NULL,
13+
`name` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT 'Equals option',
14+
`type` varchar(50) COLLATE utf8_bin NOT NULL DEFAULT 'NONE' COMMENT 'def type, NONE: 0, INPUT: 1, SELECT: 2',
15+
`sort` int(10) DEFAULT '0' COMMENT 'In order to sort the configurations that have the same level',
16+
`description` varchar(200) COLLATE utf8_bin DEFAULT NULL COMMENT 'Description of configuration',
17+
`validate_type` varchar(50) COLLATE utf8_bin DEFAULT NULL COMMENT 'Method the validate the configuration',
18+
`validate_rule` varchar(100) COLLATE utf8_bin DEFAULT NULL COMMENT 'Value of validation rule',
19+
`style` varchar(200) COLLATE utf8_bin DEFAULT '' COMMENT 'Display style',
20+
`visiable` tinyint(1) NOT NULL DEFAULT '1' COMMENT '0: hidden, 1: display',
21+
`level` tinyint(1) NOT NULL DEFAULT '1' COMMENT '0: root, 1: leaf',
22+
`unit` varchar(25) COLLATE utf8_bin DEFAULT NULL COMMENT 'Unit symbol',
23+
`default_value` varchar(200) COLLATE utf8_bin DEFAULT NULL COMMENT 'Default value',
24+
`ref_values` varchar(200) COLLATE utf8_bin DEFAULT '',
25+
`parent_ref` bigint(20) DEFAULT NULL COMMENT 'Parent key of configuration def',
26+
`required` tinyint(1) NOT NULL DEFAULT '0' COMMENT 'If the value of configuration is necessary',
27+
`is_temp` tinyint(1) DEFAULT '0' COMMENT 'Temp configuration',
28+
PRIMARY KEY (`id`),
29+
UNIQUE KEY `config_def_key` (`key`)
30+
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
31+
32+
--
33+
-- Table structure for table `linkis_stream_job_config`
34+
--
35+
36+
DROP TABLE IF EXISTS `linkis_stream_job_config`;
37+
CREATE TABLE `linkis_stream_job_config` (
38+
`job_id` bigint(20) NOT NULL,
39+
`job_name` varchar(200) COLLATE utf8_bin NOT NULL COMMENT 'Just store the job name',
40+
`key` varchar(100) COLLATE utf8_bin NOT NULL,
41+
`value` varchar(500) COLLATE utf8_bin NOT NULL,
42+
`ref_def_id` bigint(20) DEFAULT NULL COMMENT 'Refer to id in config_def table',
43+
PRIMARY KEY (`job_id`,`key`),
44+
KEY `config_def_id` (`ref_def_id`)
45+
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COLLATE=utf8_bin;
5046

5147
-- ----------------------------
5248
-- Table structure for linkis_stream_job_alarm_send_history
@@ -247,9 +243,14 @@ CREATE TABLE `linkis_stream_project_privilege` (
247243
`id` bigint(20) NOT NULL AUTO_INCREMENT,
248244
`project_id` bigint(20) NOT NULL,
249245
`user_name` varchar(100) NOT NULL,
250-
`privilege` tinyint(1) DEFAULT '0' NOT NULL COMMENT '1:发布权限 ，2:编辑权限 ，3:查看权限 ，4:所有权限 ，5:发布编辑权限 ，6:发布查看权限 ，7:编辑查看权限 ',
246+
`privilege` tinyint(1) DEFAULT '0' NOT NULL COMMENT '1:发布权限 ，2:编辑权限 ，3:查看权限',
251247
PRIMARY KEY (`id`) USING BTREE
252248
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='项目权限表';
253249

254250

251+
ALTER TABLE `linkis_stream_project` ADD create_time datetime DEFAULT NULL;
252+
ALTER TABLE `linkis_stream_project` ADD last_update_by varchar(50) DEFAULT NULL;
253+
ALTER TABLE `linkis_stream_project` ADD last_update_time datetime DEFAULT NULL;
254+
ALTER TABLE `linkis_stream_project` ADD is_deleted tinyint unsigned DEFAULT 0;
255+
255256
SET FOREIGN_KEY_CHECKS = 1;

‎db/streamis_dml.sql‎

Lines changed: 23 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -1,22 +1,25 @@
11
-- ----------------------------
2-
-- Records of linkis_stream_configuration_config_key
2+
-- Records of linkis_stream_job_config_def
33
-- ----------------------------
4-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (1, 'wds.linkis.flink.resource', '资源配置', '资源配置', NULL, 'None', NULL, 0, 0, 1, '资源配置', 1, 0, 1);
5-
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);
6-
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);
7-
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);
8-
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);
9-
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);
10-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (7, 'wds.linkis.flink.custom', '自定义参数', '自定义参数', NULL, 'None', NULL, 0, 0, 1, '自定义参数', 2, 0, 1);
11-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (8, 'wds.linkis.flink.produce', '生产配置', '生产配置', NULL, 'None', NULL, 0, 0, 1, '生产配置', 3, 0, 1);
12-
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);
13-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (10, 'wds.linkis.flink.reboot.strategy', '重启策略', '重启策略', '不重启,基于Checkpoint自动重启,无Checkpoint不重启', 'None', NULL, 0, 0, 2, '重启策略', 3, 2, 2);
14-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (11, 'wds.linkis.flink.alert', '告警设置', '告警设置', NULL, 'None', NULL, 0, 0, 1, '告警设置', 4, 0, 1);
15-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (12, 'wds.linkis.flink.alert.rule', '告警规则', '告警规则', '任务日志中出现ERROR/EXCEPTION,任务核心指标出现异常', 'None', NULL, 0, 0, 2, '告警规则', 4, 1, 2);
16-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (13, 'wds.linkis.flink.alert.user', '告警用户', '告警用户', NULL, NULL, NULL, 0, 0, 2, '告警用户', 4, 3, 1);
17-
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);
18-
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);
19-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (16, 'wds.linkis.flink.alert.failure.user', '失败时告警用户', '失败时告警用户', NULL, 'None', NULL, 0, 0, 2, '失败时告警用户', 4, 5, 1);
20-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (17, 'wds.linkis.flink.authority', '权限设置', '权限设置', NULL, 'None', NULL, 0, 0, 1, '权限设置', 5, 0, 1);
21-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (18, 'wds.linkis.flink.authority.author', '授权模式', '授权模式', '私密,指定全员可见,指定人员可见', 'None', NULL, 0, 0, 2, '授权模式', 5, 1, 2);
22-
INSERT INTO `linkis_stream_configuration_config_key` VALUES (19, 'wds.linkis.flink.authority.visible', '可见人员', '可见人员', NULL, 'None', NULL, 0, 0, 2, '可见人员', 5, 2, 1);
4+
5+
INSERT INTO `linkis_stream_job_config_def` VALUES (1,'wds.linkis.flink.resource','资源配置','NONE',0,'资源配置','None',NULL,'',1,0,NULL,NULL,'',NULL,0,0);
6+
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);
7+
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);
8+
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);
9+
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);
10+
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);
11+
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);
12+
INSERT INTO `linkis_stream_job_config_def` VALUES (8,'wds.linkis.flink.produce','生产配置','NONE',0,'生产配置','None',NULL,'',1,0,NULL,NULL,'',NULL,0,0);
13+
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);
14+
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);
15+
INSERT INTO `linkis_stream_job_config_def` VALUES (11,'wds.linkis.flink.alert','告警设置','NONE',0,'告警设置','None',NULL,'',1,1,NULL,NULL,'',NULL,0,0);
16+
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);
17+
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);
18+
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);
19+
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);
20+
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);
21+
INSERT INTO `linkis_stream_job_config_def` VALUES (32,'wds.linkis.flink.authority','权限设置','NONE',0,'权限设置','None',NULL,'',1,0,NULL,NULL,'',NULL,0,0);
22+
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);
23+
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);
24+
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);
25+
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‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,8 +38,8 @@
3838

3939
<modules>
4040
<module>streamis-jobmanager</module>
41-
<module>streamis-server</module>
4241
<module>streamis-project</module>
42+
<module>streamis-server</module>
4343
<module>assembly</module>
4444
<module>streamis-appconn</module>
4545
</modules>

‎streamis-appconn/pom.xml‎

Lines changed: 31 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,15 +30,45 @@
3030
<artifactId>json4s-jackson_2.11</artifactId>
3131
<groupId>org.json4s</groupId>
3232
</exclusion>
33+
<exclusion>
34+
<artifactId>scala-compiler</artifactId>
35+
<groupId>org.scala-lang</groupId>
36+
</exclusion>
37+
<exclusion>
38+
<artifactId>scala-library</artifactId>
39+
<groupId>org.scala-lang</groupId>
40+
</exclusion>
41+
<exclusion>
42+
<artifactId>scala-reflect</artifactId>
43+
<groupId>org.scala-lang</groupId>
44+
</exclusion>
45+
<exclusion>
46+
<artifactId>scalap</artifactId>
47+
<groupId>org.scala-lang</groupId>
48+
</exclusion>
49+
<exclusion>
50+
<artifactId>dss-common</artifactId>
51+
<groupId>com.webank.wedatasphere.dss</groupId>
52+
</exclusion>
3353
</exclusions>
3454
</dependency>
3555
<dependency>
3656
<groupId>org.apache.linkis</groupId>
3757
<artifactId>linkis-common</artifactId>
58+
<version>${linkis.version}</version>
59+
<scope>provided</scope>
3860
</dependency>
3961
<dependency>
4062
<groupId>org.apache.linkis</groupId>
4163
<artifactId>linkis-module</artifactId>
64+
<version>${linkis.version}</version>
65+
<scope>provided</scope>
66+
</dependency>
67+
<dependency>
68+
<groupId>com.webank.wedatasphere.dss</groupId>
69+
<artifactId>dss-common</artifactId>
70+
<version>${dss.version}</version>
71+
<scope>provided</scope>
4272
</dependency>
4373
</dependencies>
4474
<build>
@@ -76,7 +106,7 @@
76106
</executions>
77107
<configuration>
78108
<skipAssembly>false</skipAssembly>
79-
<finalName>out</finalName>
109+
<finalName>streamis</finalName>
80110
<appendAssemblyId>false</appendAssemblyId>
81111
<attach>false</attach>
82112
<descriptors>

‎streamis-appconn/src/main/assembly/distribution.xml‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -22,10 +22,10 @@
2222
<!-- Unique key -->
2323
<id>dss-streamis-appconn</id>
2424
<formats>
25-
<format>dir</format>
25+
<format>zip</format>
2626
</formats>
2727
<includeBaseDirectory>true</includeBaseDirectory>
28-
<baseDirectory>streamisAppConn</baseDirectory>
28+
<baseDirectory>streamis</baseDirectory>
2929

3030
<dependencySets>
3131
<dependencySet>

‎streamis-appconn/src/main/java/com/webank/wedatasphere/streamis/dss/appconn/StreamisAppConn.java‎

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,20 +1,14 @@
11
package com.webank.wedatasphere.streamis.dss.appconn;
22

3-
import com.webank.wedatasphere.dss.appconn.core.ext.ThirdlyAppConn;
3+
import com.webank.wedatasphere.dss.appconn.core.ext.SecondlyAppConn;
44
import com.webank.wedatasphere.dss.appconn.core.impl.AbstractOnlySSOAppConn;
5-
import com.webank.wedatasphere.dss.standard.app.development.standard.DevelopmentIntegrationStandard;
65
import com.webank.wedatasphere.dss.standard.app.structure.StructureIntegrationStandard;
76
import com.webank.wedatasphere.streamis.dss.appconn.structure.StreamisStructureIntegrationStandard;
87

9-
public class StreamisAppConn extends AbstractOnlySSOAppConn implements ThirdlyAppConn {
8+
public class StreamisAppConn extends AbstractOnlySSOAppConn implements SecondlyAppConn {
109

1110
private StreamisStructureIntegrationStandard structureIntegrationStandard;
1211

13-
@Override
14-
public DevelopmentIntegrationStandard getOrCreateDevelopmentStandard() {
15-
return null;
16-
}
17-
1812
@Override
1913
public StructureIntegrationStandard getOrCreateStructureStandard() {
2014
return structureIntegrationStandard;

‎streamis-appconn/src/main/java/com/webank/wedatasphere/streamis/dss/appconn/constraints/Constraints.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ public class Constraints {
1212

1313
public static final String STREAMIS_SERVER_VERSION = CommonVars.apply("wds.dss.appconn.streamis.server.version", "v1").getValue();
1414

15-
public static final String API_REQUEST_PREFIX = CommonVars.apply("wds.dss.appconn.streamis.api.request-prefix", "/api/rest_j/"+STREAMIS_SERVER_VERSION+"/streamis").getValue();
15+
public static final String API_REQUEST_PREFIX = CommonVars.apply("wds.dss.appconn.streamis.api.request-prefix", "/api/rest_j/"+STREAMIS_SERVER_VERSION+"/streamis/project").getValue();
1616

1717

1818
}

0 commit comments

Comments
 (0)