Skip to content

Commit 3625222

Browse files
authored
[Bug] Error happened when releasing application if don't need to be rebuilt (#3712)
1 parent ff3274e commit 3625222

File tree

7 files changed

+12
-10
lines changed

7 files changed

+12
-10
lines changed

streampark-console/streampark-console-service/src/main/assembly/script/schema/mysql-schema.sql

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -174,6 +174,7 @@ create table `t_flink_log` (
174174
`exception` text collate utf8mb4_general_ci,
175175
`option_time` datetime default null,
176176
`option_name` tinyint default null,
177+
`user_id` bigint default null,
177178
primary key (`id`) using btree
178179
) engine=innodb auto_increment=100000 default charset=utf8mb4 collate=utf8mb4_general_ci;
179180

streampark-console/streampark-console-service/src/main/assembly/script/schema/pgsql-schema.sql

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -415,7 +415,8 @@ create table "public"."t_flink_log" (
415415
"success" boolean,
416416
"exception" text collate "pg_catalog"."default",
417417
"option_time" timestamp(6),
418-
"option_name" int2
418+
"option_name" int2,
419+
"user_id" int8
419420
)
420421
;
421422
alter table "public"."t_flink_log" add constraint "t_flink_log_pkey" primary key ("id");

streampark-console/streampark-console-webapp/src/locales/lang/en/flink/app.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,7 @@ export default {
165165
errorStack: 'Error Stack',
166166
logTitle: 'Start Log : Job Name [ {0} ]',
167167
refreshTime: 'last refresh time',
168-
refresh: 'refresh',
168+
refresh: 'Refresh',
169169
start: 'Start Job',
170170
stop: 'Stop Job',
171171
savepoint: 'Trigger Savepoint',

streampark-console/streampark-console-webapp/src/locales/lang/en/flink/project.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ export default {
2525
successful: 'SUCCESSFUL',
2626
failed: 'FAILED',
2727
},
28-
searchPlaceholder: 'please enter a keyword search',
28+
searchPlaceholder: 'Please enter a keyword to search',
2929
form: {
3030
projectName: 'Project Name',
3131
projectNamePlaceholder: 'Please input project name',

streampark-console/streampark-console-webapp/src/locales/lang/en/routes/basic.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@ export default {
1818
login: 'Login',
1919
errorLogList: 'Error Log',
2020
notice: {
21-
message: 'notification message',
22-
exception: 'Abnormal alarm',
21+
message: 'Notification Message',
22+
exception: 'Abnormal Alarm',
2323
},
2424
};

streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkStreamingInitializer.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ private[flink] class FlinkStreamingInitializer(args: Array[String], apiType: Api
8383
val config = argsMap.get(KEY_APP_CONF(), null) match {
8484
case null | "" =>
8585
throw new ExceptionInInitializerError(
86-
"[StreamPark] Usage:can't fond config,please set \"--conf $path \" in main arguments")
86+
"[StreamPark] Usage:can't find config,please set \"--conf $path \" in main arguments")
8787
case file => file
8888
}
8989
val configMap = parseConfig(config)

streampark-flink/streampark-flink-shims/streampark-flink-shims-base/src/main/scala/org/apache/streampark/flink/core/FlinkTableInitializer.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ private[flink] class FlinkTableInitializer(args: Array[String], apiType: ApiType
9696
} else {
9797
useBlinkPlanner.setAccessible(true)
9898
useBlinkPlanner.invoke(builder)
99-
logInfo("blinkPlanner will be use.")
99+
logInfo("blinkPlanner will be used.")
100100
}
101101
case PlannerType.OLD =>
102102
val useOldPlanner = Try(builder.getClass.getDeclaredMethod("useOldPlanner")).getOrElse(null)
@@ -105,14 +105,14 @@ private[flink] class FlinkTableInitializer(args: Array[String], apiType: ApiType
105105
} else {
106106
useOldPlanner.setAccessible(true)
107107
useOldPlanner.invoke(builder)
108-
logInfo("useOldPlanner will be use.")
108+
logInfo("useOldPlanner will be used.")
109109
}
110110
case PlannerType.ANY =>
111111
val useAnyPlanner = Try(builder.getClass.getDeclaredMethod("useAnyPlanner")).getOrElse(null)
112112
if (useAnyPlanner == null) {
113113
logWarn("useAnyPlanner deprecated")
114114
} else {
115-
logInfo("useAnyPlanner will be use.")
115+
logInfo("useAnyPlanner will be used.")
116116
useAnyPlanner.setAccessible(true)
117117
useAnyPlanner.invoke(builder)
118118
}
@@ -180,7 +180,7 @@ private[flink] class FlinkTableInitializer(args: Array[String], apiType: ApiType
180180
val argsMap = ParameterTool.fromArgs(args)
181181
argsMap.get(KEY_APP_CONF(), null) match {
182182
case null | "" =>
183-
logWarn("Usage:can't fond config,you can set \"--conf $path \" in main arguments")
183+
logWarn("Usage:can't find config,you can set \"--conf $path \" in main arguments")
184184
val parameter = ParameterTool.fromSystemProperties().mergeWith(argsMap)
185185
FlinkConfiguration(parameter, new Configuration(), new Configuration())
186186
case file =>

0 commit comments

Comments
 (0)