StreamX(StreamPark 2.1.7) 更改人大金仓KES数据存储-Docker 版

斯普润布特

465人浏览 · 2026-05-25 10:54:11

斯普润布特 · 2026-05-25 10:54:11 发布

wget https://www.apache.org/dyn/closer.lua/streampark/2.1.7/apache-streampark_2.12-2.1.7-bin.tar.gz?action=download

文件名恢复

mv "apache-streampark_2.12-2.1.7-bin.tar.gz?action=download" apache-streampark_2.12-2.1.7-bin.tar.gz

解压

 tar -zxvf  apache-streampark_2.12-2.1.7-bin.tar.gz

SQL准备(支持人大金仓运行的hsql)

-- t_access_token DDL
DROP TABLE IF EXISTS "t_access_token";
CREATE TABLE "t_access_token" (
"id" bigint NOT NULL,
"user_id" bigint,
"token" varchar(1024),
"expire_time" timestamp(0),
"description" varchar(255),
"status" smallint,
"create_time" timestamp(0),
"modify_time" timestamp(0),
CONSTRAINT "t_access_token_pkey" PRIMARY KEY ("id"));

-- t_alert_config DDL
DROP TABLE IF EXISTS "t_alert_config";
CREATE SEQUENCE IF NOT EXISTS "t_alert_config_id_seq";
CREATE TABLE "t_alert_config" (
"id" bigint NOT NULL DEFAULT nextval('t_alert_config_id_seq'::regclass),
"user_id" bigint,
"alert_name" varchar(128),
"alert_type" integer DEFAULT 0,
"email_params" varchar(255),
"sms_params" text,
"ding_talk_params" text,
"we_com_params" varchar(255),
"http_callback_params" text,
"lark_params" text,
"create_time" timestamp(0),
"modify_time" timestamp(0),
CONSTRAINT "t_alert_config_pkey" PRIMARY KEY ("id"));

-- t_app_backup DDL
DROP TABLE IF EXISTS "t_app_backup";
CREATE SEQUENCE IF NOT EXISTS "t_app_backup_id_seq";
CREATE TABLE "t_app_backup" (
"id" bigint NOT NULL DEFAULT nextval('t_app_backup_id_seq'::regclass),
"app_id" bigint,
"sql_id" bigint,
"config_id" bigint,
"version" integer,
"path" text,
"description" varchar(255),
"create_time" timestamp(0),
CONSTRAINT "t_app_backup_pkey" PRIMARY KEY ("id"));

-- t_app_build_pipe DDL
DROP TABLE IF EXISTS "t_app_build_pipe";
CREATE TABLE "t_app_build_pipe" (
"app_id" bigint NOT NULL,
"pipe_type" smallint,
"pipe_status" smallint,
"cur_step" smallint,
"total_step" smallint,
"steps_status" text,
"steps_status_ts" text,
"error" text,
"build_result" text,
"modify_time" timestamp(0),
CONSTRAINT "t_app_build_pipe_pkey" PRIMARY KEY ("app_id"));

-- t_external_link DDL
DROP TABLE IF EXISTS "t_external_link";
CREATE SEQUENCE IF NOT EXISTS "t_external_link_id_seq";
CREATE TABLE "t_external_link" (
"id" bigint NOT NULL DEFAULT nextval('t_external_link_id_seq'::regclass),
"badge_label" varchar(64),
"badge_name" varchar(64),
"badge_color" varchar(64),
"link_url" text,
"create_time" timestamp(0),
"modify_time" timestamp(0),
CONSTRAINT "t_external_link_pkey" PRIMARY KEY ("id"));

-- t_flink_app DDL
DROP TABLE IF EXISTS "t_flink_app";
CREATE SEQUENCE IF NOT EXISTS "t_flink_app_id_seq";
CREATE TABLE "t_flink_app" (
"id" bigint NOT NULL DEFAULT nextval('t_flink_app_id_seq'::regclass),
"team_id" bigint NOT NULL,
"job_type" smallint,
"execution_mode" smallint,
"resource_from" smallint,
"project_id" bigint,
"job_name" varchar(255),
"module" varchar(255),
"jar" varchar(255),
"jar_check_sum" bigint,
"main_class" varchar(255),
"dependency" text,
"args" text,
"options" text,
"hot_params" text,
"user_id" bigint,
"app_type" smallint,
"duration" bigint,
"job_id" varchar(64),
"job_manager_url" varchar(255),
"version_id" bigint,
"cluster_id" varchar(45),
"k8s_namespace" varchar(63),
"flink_image" varchar(128),
"state" integer,
"restart_size" integer,
"restart_count" integer,
"cp_threshold" integer,
"cp_max_failure_interval" integer,
"cp_failure_rate_interval" integer,
"cp_failure_action" smallint,
"dynamic_properties" text,
"description" varchar(255),
"resolve_order" smallint,
"k8s_rest_exposed_type" smallint,
"jm_memory" integer,
"tm_memory" integer,
"total_task" integer,
"total_tm" integer,
"total_slot" integer,
"available_slot" integer,
"option_state" smallint,
"tracking" smallint,
"create_time" timestamp(0),
"modify_time" timestamp(0),
"option_time" timestamp(0),
"release" smallint DEFAULT 1,
"build" smallint DEFAULT 1,
"start_time" timestamp(0),
"end_time" timestamp(0),
"alert_id" bigint,
"k8s_pod_template" text,
"k8s_jm_pod_template" text,
"k8s_tm_pod_template" text,
"k8s_hadoop_integration" smallint DEFAULT 0,
"flink_cluster_id" bigint,
"ingress_template" text,
"default_mode_ingress" text,
"tags" varchar(500),
CONSTRAINT "t_flink_app_pkey" PRIMARY KEY ("id"));

-- t_flink_cluster DDL
DROP TABLE IF EXISTS "t_flink_cluster";
CREATE SEQUENCE IF NOT EXISTS "t_flink_cluster_id_seq";
CREATE TABLE "t_flink_cluster" (
"id" bigint NOT NULL DEFAULT nextval('t_flink_cluster_id_seq'::regclass),
"address" varchar(150),
"cluster_id" varchar(45),
"cluster_name" varchar(128) NOT NULL,
"options" text,
"yarn_queue" varchar(128),
"execution_mode" smallint NOT NULL DEFAULT 1,
"version_id" bigint NOT NULL,
"k8s_namespace" varchar(63) DEFAULT 'default'::varchar,
"service_account" varchar(64),
"description" varchar(255),
"user_id" bigint,
"flink_image" varchar(128),
"dynamic_properties" text,
"k8s_rest_exposed_type" smallint DEFAULT 2,
"k8s_hadoop_integration" smallint DEFAULT 0,
"k8s_conf" varchar(255),
"resolve_order" integer,
"exception" text,
"cluster_state" smallint DEFAULT 0,
"create_time" timestamp(0),
CONSTRAINT "t_flink_cluster_pkey" PRIMARY KEY ("id"));

-- t_flink_config DDL
DROP TABLE IF EXISTS "t_flink_config";
CREATE SEQUENCE IF NOT EXISTS "t_flink_config_id_seq";
CREATE TABLE "t_flink_config" (
"id" bigint NOT NULL DEFAULT nextval('t_flink_config_id_seq'::regclass),
"app_id" bigint NOT NULL,
"format" smallint NOT NULL DEFAULT 0,
"version" integer NOT NULL,
"latest" smallint NOT NULL DEFAULT 0,
"content" text NOT NULL,
"create_time" timestamp(0),
CONSTRAINT "t_flink_config_pkey" PRIMARY KEY ("id"));

-- t_flink_effective DDL
DROP TABLE IF EXISTS "t_flink_effective";
CREATE SEQUENCE IF NOT EXISTS "t_flink_effective_id_seq";
CREATE TABLE "t_flink_effective" (
"id" bigint NOT NULL DEFAULT nextval('t_flink_effective_id_seq'::regclass),
"app_id" bigint NOT NULL,
"target_type" smallint NOT NULL,
"target_id" bigint NOT NULL,
"create_time" timestamp(0),
CONSTRAINT "t_flink_effective_pkey" PRIMARY KEY ("id"));

-- t_flink_env DDL
DROP TABLE IF EXISTS "t_flink_env";
CREATE SEQUENCE IF NOT EXISTS "t_flink_env_id_seq";
CREATE TABLE "t_flink_env" (
"id" bigint NOT NULL DEFAULT nextval('t_flink_env_id_seq'::regclass),
"flink_name" varchar(128) NOT NULL,
"flink_home" varchar(255) NOT NULL,
"version" varchar(64) NOT NULL,
"scala_version" varchar(64) NOT NULL,
"flink_conf" text NOT NULL,
"is_default" smallint NOT NULL DEFAULT 0,
"description" varchar(255),
"create_time" timestamp(0),
CONSTRAINT "t_flink_env_pkey" PRIMARY KEY ("id"));

-- t_flink_log DDL
DROP TABLE IF EXISTS "t_flink_log";
CREATE SEQUENCE IF NOT EXISTS "t_flink_log_id_seq";
CREATE TABLE "t_flink_log" (
"id" bigint NOT NULL DEFAULT nextval('t_flink_log_id_seq'::regclass),
"app_id" bigint,
"yarn_app_id" varchar(64),
"job_manager_url" varchar(255),
"success" smallint,
"exception" text,
"option_time" timestamp(0),
"option_name" smallint,
CONSTRAINT "t_flink_log_pkey" PRIMARY KEY ("id"));

-- t_flink_project DDL
DROP TABLE IF EXISTS "t_flink_project";
CREATE SEQUENCE IF NOT EXISTS "t_flink_project_id_seq";
CREATE TABLE "t_flink_project" (
"id" bigint NOT NULL DEFAULT nextval('t_flink_project_id_seq'::regclass),
"team_id" bigint NOT NULL,
"name" varchar(255),
"url" varchar(255),
"refs" varchar(255),
"user_name" varchar(64),
"password" varchar(64),
"prvkey_path" varchar(128),
"pom" varchar(255),
"build_args" varchar(255),
"type" smallint,
"repository" smallint,
"last_build" timestamp(0),
"description" varchar(255),
"build_state" smallint DEFAULT '-1'::integer,
"create_time" timestamp(0),
"modify_time" timestamp(0),
CONSTRAINT "t_flink_project_pkey" PRIMARY KEY ("id"));

-- t_flink_savepoint DDL
DROP TABLE IF EXISTS "t_flink_savepoint";
CREATE SEQUENCE IF NOT EXISTS "t_flink_savepoint_id_seq";
CREATE TABLE "t_flink_savepoint" (
"id" bigint NOT NULL DEFAULT nextval('t_flink_savepoint_id_seq'::regclass),
"app_id" bigint NOT NULL,
"chk_id" bigint,
"type" smallint,
"path" varchar(255),
"latest" smallint NOT NULL DEFAULT 1,
"trigger_time" timestamp(0),
"create_time" timestamp(0),
CONSTRAINT "t_flink_savepoint_pkey" PRIMARY KEY ("id"));

-- t_flink_sql DDL
DROP TABLE IF EXISTS "t_flink_sql";
CREATE SEQUENCE IF NOT EXISTS "t_flink_sql_id_seq";
CREATE TABLE "t_flink_sql" (
"id" bigint NOT NULL DEFAULT nextval('t_flink_sql_id_seq'::regclass),
"app_id" bigint,
"sql" text,
"dependency" text,
"version" integer,
"candidate" smallint NOT NULL DEFAULT 1,
"create_time" timestamp(0),
CONSTRAINT "t_flink_sql_pkey" PRIMARY KEY ("id"));

-- t_member DDL
DROP TABLE IF EXISTS "t_member";
CREATE SEQUENCE IF NOT EXISTS "t_member_id_seq";
CREATE TABLE "t_member" (
"id" bigint NOT NULL DEFAULT nextval('t_member_id_seq'::regclass),
"team_id" bigint NOT NULL,
"user_id" bigint NOT NULL,
"role_id" bigint NOT NULL,
"create_time" timestamp(0),
"modify_time" timestamp(0),
CONSTRAINT "t_member_pkey" PRIMARY KEY ("id"));

-- t_menu DDL
DROP TABLE IF EXISTS "t_menu";
CREATE SEQUENCE IF NOT EXISTS "t_menu_menu_id_seq";
CREATE TABLE "t_menu" (
"menu_id" bigint NOT NULL DEFAULT nextval('t_menu_menu_id_seq'::regclass),
"parent_id" bigint NOT NULL,
"menu_name" varchar(64) NOT NULL,
"path" varchar(64),
"component" varchar(64),
"perms" varchar(64),
"icon" varchar(64),
"type" bpchar(2),
"display" smallint NOT NULL DEFAULT 1,
"order_num" integer,
"create_time" timestamp(0),
"modify_time" timestamp(0),
CONSTRAINT "t_menu_pkey" PRIMARY KEY ("menu_id"));

-- t_message DDL
DROP TABLE IF EXISTS "t_message";
CREATE SEQUENCE IF NOT EXISTS "t_message_id_seq";
CREATE TABLE "t_message" (
"id" bigint NOT NULL DEFAULT nextval('t_message_id_seq'::regclass),
"app_id" bigint,
"user_id" bigint,
"type" smallint,
"title" varchar(255),
"context" text,
"is_read" smallint DEFAULT 0,
"create_time" timestamp(0),
CONSTRAINT "t_message_pkey" PRIMARY KEY ("id"));

-- t_role DDL
DROP TABLE IF EXISTS "t_role";
CREATE SEQUENCE IF NOT EXISTS "t_role_role_id_seq";
CREATE TABLE "t_role" (
"role_id" bigint NOT NULL DEFAULT nextval('t_role_role_id_seq'::regclass),
"role_name" varchar(64) NOT NULL,
"create_time" timestamp(0),
"modify_time" timestamp(0),
"description" varchar(255),
CONSTRAINT "t_role_pkey" PRIMARY KEY ("role_id"));

-- t_role_menu DDL
DROP TABLE IF EXISTS "t_role_menu";
CREATE SEQUENCE IF NOT EXISTS "t_role_menu_id_seq";
CREATE TABLE "t_role_menu" (
"id" bigint NOT NULL DEFAULT nextval('t_role_menu_id_seq'::regclass),
"role_id" bigint NOT NULL,
"menu_id" bigint NOT NULL,
CONSTRAINT "t_role_menu_pkey" PRIMARY KEY ("id"));

-- t_setting DDL
DROP TABLE IF EXISTS "t_setting";
CREATE TABLE "t_setting" (
"order_num" integer,
"setting_key" varchar(64) NOT NULL,
"setting_value" text,
"setting_name" varchar(255),
"description" varchar(255),
"type" smallint NOT NULL,
CONSTRAINT "t_setting_pkey" PRIMARY KEY ("setting_key"));

-- t_team DDL
DROP TABLE IF EXISTS "t_team";
CREATE SEQUENCE IF NOT EXISTS "t_team_id_seq";
CREATE TABLE "t_team" (
"id" bigint NOT NULL DEFAULT nextval('t_team_id_seq'::regclass),
"team_name" varchar(64) NOT NULL,
"description" varchar(255),
"create_time" timestamp(0),
"modify_time" timestamp(0),
CONSTRAINT "t_team_pkey" PRIMARY KEY ("id"));

-- t_user DDL
DROP TABLE IF EXISTS "t_user";
CREATE SEQUENCE IF NOT EXISTS "t_user_user_id_seq";
CREATE TABLE "t_user" (
"user_id" bigint NOT NULL DEFAULT nextval('t_user_user_id_seq'::regclass),
"username" varchar(64) NOT NULL,
"nick_name" varchar(64) NOT NULL,
"salt" varchar(26),
"password" varchar(64) NOT NULL,
"email" varchar(64),
"user_type" integer NOT NULL,
"login_type" smallint DEFAULT 0,
"last_team_id" bigint,
"status" bpchar(1) NOT NULL,
"create_time" timestamp(0),
"modify_time" timestamp(0),
"last_login_time" timestamp(0),
"sex" bpchar(1),
"avatar" varchar(128),
"description" varchar(255),
CONSTRAINT "t_user_pkey" PRIMARY KEY ("user_id"));

-- t_variable DDL
DROP TABLE IF EXISTS "t_variable";
CREATE SEQUENCE IF NOT EXISTS "t_variable_id_seq";
CREATE TABLE "t_variable" (
"id" bigint NOT NULL DEFAULT nextval('t_variable_id_seq'::regclass),
"variable_code" varchar(128) NOT NULL,
"variable_value" text NOT NULL,
"description" text,
"creator_id" bigint NOT NULL,
"team_id" bigint NOT NULL,
"desensitization" smallint NOT NULL DEFAULT 0,
"create_time" timestamp(0),
"modify_time" timestamp(0),
CONSTRAINT "t_variable_pkey" PRIMARY KEY ("id"));

-- t_yarn_queue DDL
DROP TABLE IF EXISTS "t_yarn_queue";
CREATE SEQUENCE IF NOT EXISTS "t_yarn_queue_id_seq";
CREATE TABLE "t_yarn_queue" (
"id" bigint NOT NULL DEFAULT nextval('t_yarn_queue_id_seq'::regclass),
"team_id" bigint NOT NULL,
"queue_label" varchar(128) NOT NULL,
"description" varchar(255),
"create_time" timestamp(0),
"modify_time" timestamp(0),
CONSTRAINT "t_yarn_queue_pkey" PRIMARY KEY ("id"));

-- t_alert_config Constraints
CREATE INDEX "inx_alert_user" ON "t_alert_config" USING btree ("user_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST);

-- t_flink_app Constraints
CREATE INDEX "inx_job_type" ON "t_flink_app" USING btree ("job_type"  "pg_catalog"."int2_ops" ASC NULLS FIRST);
CREATE INDEX "inx_team" ON "t_flink_app" USING btree ("team_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST);
CREATE INDEX "inx_track" ON "t_flink_app" USING btree ("tracking"  "pg_catalog"."int2_ops" ASC NULLS FIRST);

-- t_flink_cluster Constraints
CREATE UNIQUE INDEX "id_unique" ON "t_flink_cluster" USING btree ("cluster_id" COLLATE "pg_catalog"."ci_x_icu" "pg_catalog"."text_ops" ASC NULLS FIRST,"address" COLLATE "pg_catalog"."ci_x_icu" "pg_catalog"."text_ops" ASC NULLS FIRST,"execution_mode"  "pg_catalog"."int2_ops" ASC NULLS FIRST);

-- t_flink_effective Constraints
CREATE UNIQUE INDEX "un_effective_inx" ON "t_flink_effective" USING btree ("app_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST,"target_type"  "pg_catalog"."int2_ops" ASC NULLS FIRST);

-- t_flink_env Constraints
CREATE UNIQUE INDEX "un_env_name" ON "t_flink_env" USING btree ("flink_name" COLLATE "pg_catalog"."ci_x_icu" "pg_catalog"."text_ops" ASC NULLS FIRST);

-- t_flink_project Constraints
CREATE INDEX "inx_team_idx" ON "t_flink_project" USING btree ("team_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST);

-- t_member Constraints
CREATE UNIQUE INDEX "un_user_team_role_inx" ON "t_member" USING btree ("user_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST,"team_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST,"role_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST);

-- t_message Constraints
CREATE INDEX "inx_mes_user" ON "t_message" USING btree ("user_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST);

-- t_role_menu Constraints
CREATE UNIQUE INDEX "un_role_menu_inx" ON "t_role_menu" USING btree ("role_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST,"menu_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST);

-- t_team Constraints
CREATE UNIQUE INDEX "team_name_idx" ON "t_team" USING btree ("team_name" COLLATE "pg_catalog"."ci_x_icu" "pg_catalog"."text_ops" ASC NULLS FIRST);

-- t_user Constraints
CREATE UNIQUE INDEX "un_username" ON "t_user" USING btree ("username" COLLATE "pg_catalog"."ci_x_icu" "pg_catalog"."text_ops" ASC NULLS FIRST);

-- t_variable Constraints
CREATE UNIQUE INDEX "un_team_vcode_inx" ON "t_variable" USING btree ("team_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST,"variable_code" COLLATE "pg_catalog"."ci_x_icu" "pg_catalog"."text_ops" ASC NULLS FIRST);

-- t_yarn_queue Constraints
CREATE UNIQUE INDEX "unq_team_id_queue_label" ON "t_yarn_queue" USING btree ("team_id"  "pg_catalog"."int8_ops" ASC NULLS FIRST,"queue_label" COLLATE "pg_catalog"."ci_x_icu" "pg_catalog"."text_ops" ASC NULLS FIRST);

-- t_flink_app DML
INSERT INTO "t_flink_app" ("id","team_id","job_type","execution_mode","resource_from","project_id","job_name","module","jar","jar_check_sum","main_class","dependency","args","options","hot_params","user_id","app_type","duration","job_id","job_manager_url","version_id","cluster_id","k8s_namespace","flink_image","state","restart_size","restart_count","cp_threshold","cp_max_failure_interval","cp_failure_rate_interval","cp_failure_action","dynamic_properties","description","resolve_order","k8s_rest_exposed_type","jm_memory","tm_memory","total_task","total_tm","total_slot","available_slot","option_state","tracking","create_time","modify_time","option_time","release","build","start_time","end_time","alert_id","k8s_pod_template","k8s_jm_pod_template","k8s_tm_pod_template","k8s_hadoop_integration","flink_cluster_id","ingress_template","default_mode_ingress","tags") VALUES (100000,100000,2,4,NULL,NULL,'Flink SQL Demo',NULL,NULL,NULL,NULL,NULL,NULL,NULL,NULL,100000,1,NULL,NULL,NULL,NULL,NULL,NULL,NULL,0,0,NULL,NULL,NULL,NULL,NULL,NULL,'Flink SQL Demo',0,NULL,NULL,NULL,NULL,NULL,NULL,NULL,0,0,'2026-05-21 17:00:40','2026-05-21 17:00:40',NULL,1,1,NULL,NULL,NULL,NULL,NULL,NULL,0,NULL,NULL,NULL,'streampark,test');
-- t_flink_effective DML
INSERT INTO "t_flink_effective" ("id","app_id","target_type","target_id","create_time") VALUES (100000,100000,2,100000,'2026-05-21 17:00:40');
-- t_flink_project DML
INSERT INTO "t_flink_project" ("id","team_id","name","url","refs","user_name","password","prvkey_path","pom","build_args","type","repository","last_build","description","build_state","create_time","modify_time") VALUES (100000,100000,'streampark-quickstart','https://github.com/apache/streampark-quickstart','release-2.0.0',NULL,NULL,NULL,NULL,NULL,1,1,NULL,'streampark-quickstart',-1,'2026-05-21 17:00:40','2026-05-21 17:00:40');
-- t_flink_sql DML
INSERT INTO "t_flink_sql" ("id","app_id","sql","dependency","version","candidate","create_time") VALUES (100000,100000,'eNqlUUtPhDAQvu+vmFs1AYIHT5s94AaVqGxSSPZIKgxrY2mxrdGfb4GS3c0+LnJo6Mz36syapkmZQpk8vKbQMMt2KOFmAe5rK4Nf3yhrhCwvA1/TTDaqO61UxmooSprlT1PDGkgKEKpmwvIOjWVdP3W2zpG+JfQFHjfU46xxrVvYZuWztye1khJrqzSBFRCfjUwSYQiqt1xJJvyPcbWJp9WPCXvUoUEn0ZAVufcs0nIUjYn2L4s++YiY75eBLr+2Dnl3GYKTWRyfQKYRRR2XZxXmNvu9yh9GHAmUO/sxyMRkGNly4c714RZ7zaWtLHsX+N9NjvVrWxm99jmyvEhpOUhujmIYFI5zkCOYzYIj11a7QH7Tyz+nE8bw',NULL,1,1,'2026-05-21 17:00:40');
-- t_member DML
INSERT INTO "t_member" ("id","team_id","user_id","role_id","create_time","modify_time") VALUES (100000,100000,100000,100001,'2026-05-21 17:00:42','2026-05-21 17:00:42');
-- t_menu DML
INSERT INTO "t_menu" ("menu_id","parent_id","menu_name","path","component","perms","icon","type","display","order_num","create_time","modify_time") VALUES (110000,0,'menu.system','/system','PageView',NULL,NULL,'0',1,3,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120000,0,'Apache Flink','/flink','PageView',NULL,NULL,'0',1,1,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(130000,0,'menu.setting','/setting','PageView',NULL,NULL,'0',1,2,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110100,110000,'menu.userManagement','/system/user','system/user/User',NULL,'user','0',1,1,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110200,110000,'menu.roleManagement','/system/role','system/role/Role',NULL,'smile','0',1,2,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110300,110000,'menu.menuManagement','/system/menu','system/menu/Menu','menu:view','bars','0',1,3,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110400,110000,'menu.tokenManagement','/system/token','system/token/Token',NULL,'lock','0',1,1,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110500,110000,'menu.teamManagement','/system/team','system/team/Team',NULL,'team','0',1,2,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110600,110000,'menu.memberManagement','/system/member','system/member/Member',NULL,'usergroup-add','0',1,2,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120100,120000,'menu.project','/flink/project','flink/project/View',NULL,'github','0',1,1,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120200,120000,'menu.application','/flink/app','flink/app/View',NULL,'mobile','0',1,2,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120300,120000,'menu.variable','/flink/variable','flink/variable/View',NULL,'code','0',1,3,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(130100,130000,'setting.system','/setting/system','setting/System/index',NULL,'database','0',1,1,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(130200,130000,'setting.alarm','/setting/alarm','setting/Alarm/index',NULL,'alert','0',1,2,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(130300,130000,'setting.flinkHome','/setting/flinkHome','setting/FlinkHome/index',NULL,'desktop','0',1,3,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(130400,130000,'setting.flinkCluster','/setting/flinkCluster','setting/FlinkCluster/index','menu:view','cluster','0',1,4,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(130500,130000,'setting.externalLink','/setting/externalLink','setting/ExternalLink/index','menu:view','link','0',1,5,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(130600,130000,'setting.yarnQueue','/setting/yarnQueue','setting/YarnQueue/index','menu:view','bars','0',1,6,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110101,110100,'add',NULL,NULL,'user:add',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110102,110100,'update',NULL,NULL,'user:update',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110103,110100,'delete',NULL,NULL,'user:delete',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110104,110100,'reset',NULL,NULL,'user:reset',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110105,110100,'types',NULL,NULL,'user:types',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110106,110100,'view',NULL,NULL,'user:view',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110201,110200,'add',NULL,NULL,'role:add',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110202,110200,'update',NULL,NULL,'role:update',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110203,110200,'delete',NULL,NULL,'role:delete',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110204,110200,'view',NULL,NULL,'role:view',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110401,110400,'add',NULL,NULL,'token:add',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110402,110400,'delete',NULL,NULL,'token:delete',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110403,110400,'view',NULL,NULL,'token:view',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110501,110500,'add',NULL,NULL,'team:add',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110502,110500,'update',NULL,NULL,'team:update',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110503,110500,'delete',NULL,NULL,'team:delete',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110504,110500,'view',NULL,NULL,'team:view',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110601,110600,'add',NULL,NULL,'member:add',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110602,110600,'update',NULL,NULL,'member:update',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110603,110600,'delete',NULL,NULL,'member:delete',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110604,110600,'role view',NULL,NULL,'role:view',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(110605,110600,'view',NULL,NULL,'member:view',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120101,120100,'add','/flink/project/add','flink/project/Add','project:create','','0',0,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120102,120100,'build',NULL,NULL,'project:build',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120103,120100,'delete',NULL,NULL,'project:delete',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120104,120100,'edit','/flink/project/edit','flink/project/Edit','project:update',NULL,'0',0,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120105,120100,'view',NULL,NULL,'project:view',NULL,'1',1,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120201,120200,'add','/flink/app/add','flink/app/Add','app:create','','0',0,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120202,120200,'detail app','/flink/app/detail','flink/app/Detail','app:detail','','0',0,NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40'),(120203,120200,'edit flink','/flink/app/edit_flink','flink/app/EditFlink','app:update','','0',0,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120204,120200,'edit streampark','/flink/app/edit_streampark','flink/app/EditStreamPark','app:update','','0',0,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120205,120200,'mapping',NULL,NULL,'app:mapping',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120206,120200,'release',NULL,NULL,'app:release',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120207,120200,'start',NULL,NULL,'app:start',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120208,120200,'clean',NULL,NULL,'app:clean',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120209,120200,'cancel',NULL,NULL,'app:cancel',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120210,120200,'savepoint delete',NULL,NULL,'savepoint:delete',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120211,120200,'backup rollback',NULL,NULL,'backup:rollback',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120212,120200,'backup delete',NULL,NULL,'backup:delete',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120213,120200,'conf delete',NULL,NULL,'conf:delete',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120214,120200,'delete',NULL,NULL,'app:delete',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120215,120200,'copy',NULL,NULL,'app:copy',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120216,120200,'view',NULL,NULL,'app:view',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120217,120200,'savepoint trigger',NULL,NULL,'savepoint:trigger',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120218,120200,'sql delete',NULL,NULL,'sql:delete',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120301,120300,'add',NULL,NULL,'variable:add',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120302,120300,'update',NULL,NULL,'variable:update',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120303,120300,'delete',NULL,NULL,'variable:delete',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120304,120300,'depend apps','/flink/variable/depend_apps','flink/variable/DependApps','variable:depend_apps','','0',0,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120305,120300,'show original',NULL,NULL,'variable:show_original',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120306,120300,'view',NULL,NULL,'variable:view',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(120307,120300,'depend view',NULL,NULL,'variable:depend_apps',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130101,130100,'view',NULL,NULL,'setting:view',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130102,130100,'setting update',NULL,NULL,'setting:update',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130401,130400,'add cluster','/setting/add_cluster','setting/FlinkCluster/AddCluster','cluster:create','','0',0,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130402,130400,'edit cluster','/setting/edit_cluster','setting/FlinkCluster/EditCluster','cluster:update','','0',0,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130501,130500,'link view',NULL,NULL,'externalLink:view',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130502,130500,'link create',NULL,NULL,'externalLink:create',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130503,130500,'link update',NULL,NULL,'externalLink:update',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130504,130500,'link delete',NULL,NULL,'externalLink:delete',NULL,'1',1,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130601,130600,'add yarn queue',NULL,NULL,'yarnQueue:create','','1',0,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130602,130600,'edit yarn queue',NULL,NULL,'yarnQueue:update','','1',0,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41'),(130603,130600,'delete yarn queue',NULL,NULL,'yarnQueue:delete','','1',0,NULL,'2026-05-21 17:00:41','2026-05-21 17:00:41');
-- t_role DML
INSERT INTO "t_role" ("role_id","role_name","create_time","modify_time","description") VALUES (100001,'developer','2026-05-21 17:00:41','2026-05-21 17:00:41','developer'),(100002,'team admin','2026-05-21 17:00:41','2026-05-21 17:00:41','Team Admin has all permissions inside the team.');
-- t_role_menu DML
INSERT INTO "t_role_menu" ("id","role_id","menu_id") VALUES (1,100001,120000),(2,100001,120100),(3,100001,120101),(4,100001,120102),(5,100001,120104),(6,100001,120105),(7,100001,120200),(8,100001,120201),(9,100001,120202),(10,100001,120203),(11,100001,120204),(12,100001,120206),(13,100001,120207),(14,100001,120208),(15,100001,120209),(16,100001,120210),(17,100001,120211),(18,100001,120212),(19,100001,120213),(20,100001,120215),(21,100001,120216),(22,100001,120217),(23,100001,120300),(24,100001,120304),(25,100001,120306),(26,100001,120307),(27,100001,130000),(28,100001,130100),(29,100001,130101),(30,100002,110000),(31,100002,110600),(32,100002,110601),(33,100002,110602),(34,100002,110603),(35,100002,110604),(36,100002,110605),(37,100002,120000),(38,100002,120100),(39,100002,120101),(40,100002,120102),(41,100002,120103),(42,100002,120104),(43,100002,120105),(44,100002,120200),(45,100002,120201),(46,100002,120202),(47,100002,120203),(48,100002,120204),(49,100002,120205),(50,100002,120206),(51,100002,120207),(52,100002,120208),(53,100002,120209),(54,100002,120210),(55,100002,120211),(56,100002,120212),(57,100002,120213),(58,100002,120214),(59,100002,120215),(60,100002,120216),(61,100002,120217),(62,100002,120218),(63,100002,120300),(64,100002,120301),(65,100002,120302),(66,100002,120303),(67,100002,120304),(68,100002,120305),(69,100002,120306),(70,100002,120307),(71,100002,130000),(72,100002,130100),(73,100002,130101),(74,100002,130200),(75,100002,130300),(76,100002,130400),(77,100002,130401),(78,100002,130402),(79,100002,130500),(80,100002,130501),(81,100002,130502),(82,100002,130503),(83,100002,130504),(84,100002,130600),(85,100002,130601),(86,100002,130602),(87,100002,130603);
-- t_setting DML
INSERT INTO "t_setting" ("order_num","setting_key","setting_value","setting_name","description","type") VALUES (1,'streampark.maven.settings',NULL,'Maven Settings File Path','Maven Settings.xml full path',1),(2,'streampark.maven.central.repository',NULL,'Maven Central Repository','Maven private server address',1),(3,'streampark.maven.auth.user',NULL,'Maven Central Repository Auth User','Maven private server authentication username',1),(4,'streampark.maven.auth.password',NULL,'Maven Central Repository Auth Password','Maven private server authentication password',1),(5,'alert.email.host',NULL,'Alert Email Smtp Host','Alert Mailbox Smtp Host',1),(6,'alert.email.port',NULL,'Alert Email Smtp Port','Smtp Port of the alarm mailbox',1),(7,'alert.email.from',NULL,'Alert Sender Email','Email to send alerts',1),(8,'alert.email.userName',NULL,'Alert  Email User','Authentication username used to send alert emails',1),(9,'alert.email.password',NULL,'Alert Email Password','Authentication password used to send alarm email',1),(10,'alert.email.ssl','false','Alert Email SSL','Whether to enable SSL in the mailbox that sends the alert',2),(11,'docker.register.address',NULL,'Docker Register Address','Docker container service address',1),(12,'docker.register.user',NULL,'Docker Register User','Docker container service authentication username',1),(13,'docker.register.password',NULL,'Docker Register Password','Docker container service authentication password',1),(14,'docker.register.namespace',NULL,'Docker namespace','Namespace for docker image used in docker building env and target image register',1),(15,'ingress.mode.default',NULL,'Ingress domain address','Automatically generate an nginx-based ingress by passing in a domain name',1);
-- t_team DML
INSERT INTO "t_team" ("id","team_name","description","create_time","modify_time") VALUES (100000,'default',NULL,'2026-05-21 17:00:40','2026-05-21 17:00:40');
-- t_user DML
INSERT INTO "t_user" ("user_id","username","nick_name","salt","password","email","user_type","login_type","last_team_id","status","create_time","modify_time","last_login_time","sex","avatar","description") VALUES (100000,'admin','','rh8b1ojwog777yrg0daesf04gk','2513f3748847298ea324dffbf67fe68681dd92315bda830065facd8efe08f54f',NULL,1,0,100000,'1','2026-05-21 17:00:42','2026-05-21 17:00:42',NULL,'0',NULL,NULL);

更改配置文件

vim /opt/streampark/apache-streampark_2.12-2.1.7-bin/conf/config.yaml


#
# StreamPark 2.1.7 + 人大金仓（方案 A：jdbc:postgresql + 内置 org.postgresql.Driver）
# 部署路径：复制到 $STREAMPARK_HOME/conf/config.yaml
# 若存在 conf/application.yml，请重命名备份，避免优先走旧配置。
#

logging:
  level:
    root: info

server:
  port: 10000
  session:
    ttl: 2h
  undertow:
    buffer-size: 1024
    direct-buffers: true
    threads:
      io: 16
      worker: 256

datasource:
  dialect: pgsql
  username: kes
  password: 123456
  url: jdbc:postgresql://192.168.18.100:54321/kes_db?stringtype=unspecified&currentSchema=stream_park&autosave=always&cleanupSavepoints=true

streampark:
  workspace:
    local: /tmp/streampark
    remote: hdfs:///streampark/
  proxy:
    lark-url:
    yarn-url:
  yarn:
    http-auth: 'simple'
  hadoop-user-name: hdfs
  project:
    max-build: 16
  openapi.white-list:

security:
  kerberos:
    login:
      debug: false
      enable: false
      keytab:
      krb5:
      principal:
    ttl: 2h

ldap:
  base-dn: dc=streampark,dc=com
  enable: false
  username: cn=Manager,dc=streampark,dc=com
  password: streampark
  urls: ldap://99.99.99.99:389
  user:
    email-attribute: mail
    identity-attribute: uid

编写Dockerfile

vim /opt/streampark/apache-streampark_2.12-2.1.7-bin/Dockerfile

FROM openjdk:11-jre-slim

WORKDIR /streampark

RUN mkdir -p /tmp/streampark && chmod 777 /tmp/streampark

COPY . .

EXPOSE 10000

# 与官方镜像一致：前台启动，便于 Docker 保活与排错
ENTRYPOINT ["/streampark/bin/streampark.sh", "start_docker"]

构建镜像

cd /opt/streampark/apache-streampark_2.12-2.1.7-bin

docker build -t streampark:2.1.7-kes .

启动实例

docker run -d --name streampark \
  -p 10000:10000 \
  -v /tmp/streampark:/tmp/streampark \
  streampark:2.1.7-kes

端口检查

docker port streampark

curl -I http://127.0.0.1:10000/

镜像备份

docker save -o streampark-2.1.7-kes.tar streampark:2.1.7-kes

镜像恢复
```
docker load -i streampark:2.1.7-kes
```

问题定位

# 1. 看真实启动日志（banner 打印不代表启动成功）
docker exec -it streampark tail -200 /streampark/logs/streampark.out

# 2. 搜数据库相关错误
docker exec -it streampark grep -iE "error|exception|flyway|datasource|SQLException" /streampark/logs/streampark.out | tail -50

# 3. 从容器内测金仓连通性
docker exec -it streampark bash -c "apt-get update -qq && apt-get install -y -qq netcat-openbsd 2>/dev/null; nc -zv 10.13.73.7 54321"

https://edu.csdn.net/learn/39067/627173?utm_source=2019755004

汇聚全球AI编程工具，助力开发者即刻编程。

更多推荐

一个 API 入口调用多个大模型：AiiOnly客户端 + CC Switch 打通 Codex AI编程流程

AI编程社区

VSCode Claude Code + MiMo 中转免登录完整配置教程（解决原生登录弹窗 + 模型报错）

AI编程社区

压缩完上下文后，Agent 怎么还记得你的开发习惯

本文介绍了Claude代码项目中Memory机制的实现，用于跨任务保存关键信息。Memory分为用户偏好、反馈意见、项目背景和参考线索四类，存储在.memory/目录下的独立Markdown文件中，并通过MEMORY.md目录索引。Agent通过轻量模型调用选择相关记忆加载，每次最多读取5条。记忆提取发生在消息压缩前，以保留原始完整信息。当记忆文件达到10条时会触发合并整理，但存在信息失真的风险。