This is an automated email from the ASF dual-hosted git repository.
benjobs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampark.git
The following commit(s) were added to refs/heads/dev by this push:
new d04160846 [Improve] Translate comments into English for
FlinkAppState.java (#2623)
d04160846 is described below
commit d04160846177ac19242b231fda5a3b70234a304c
Author: sober <[email protected]>
AuthorDate: Sun Apr 16 14:57:30 2023 +0800
[Improve] Translate comments into English for FlinkAppState.java (#2623)
* [Improve] Translate comments into English for FlinkAppState.java
* Translate comments into English
---
.../console/core/enums/FlinkAppState.java | 23 +++++++++++++---------
.../console/core/enums/GitAuthorizedError.java | 8 ++++----
2 files changed, 18 insertions(+), 13 deletions(-)
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/FlinkAppState.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/FlinkAppState.java
index 33d53d5db..6e558a65a 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/FlinkAppState.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/FlinkAppState.java
@@ -28,7 +28,7 @@ import scala.Enumeration;
@Getter
public enum FlinkAppState implements Serializable {
- /** added new job to database */
+ /** Added new job to database. */
ADDED(0),
/**
@@ -38,11 +38,13 @@ public enum FlinkAppState implements Serializable {
/** Job is newly created, no task has started to run. */
CREATED(2),
+
/** Application which is currently running. */
STARTING(3),
/** Application which is currently running. */
RESTARTING(4),
+
/** Some tasks are scheduled or running, some may be pending, some may be
finished. */
RUNNING(5),
@@ -66,18 +68,20 @@ public enum FlinkAppState implements Serializable {
* potential HA job store.
*/
SUSPENDED(11),
+
/** The job is currently reconciling and waits for task execution report to
recover state. */
RECONCILING(12),
- /** 失联 */
+
+ /** Loss of mapping. */
LOST(13),
- /** 射影中... */
+ /** Mapping. */
MAPPING(14),
- /** 其他不关心的状态... */
+ /** Other statuses. */
OTHER(15),
- /** has rollback */
+ /** Has rollback. */
REVOKED(16),
/**
@@ -86,15 +90,16 @@ public enum FlinkAppState implements Serializable {
*/
SILENT(17),
- /** Flink job has terminated vaguely, maybe FINISHED, CANCELED or FAILED */
+ /** Flink job has terminated vaguely, maybe FINISHED, CANCELED or FAILED. */
TERMINATED(18),
- /** Flink job has terminated vaguely, maybe FINISHED, CANCELED or FAILED */
+ /** Flink job has terminated vaguely, maybe FINISHED, CANCELED or FAILED. */
POS_TERMINATED(19),
- /** job SUCCEEDED on yarn */
+ /** Job SUCCEEDED on yarn. */
SUCCEEDED(20),
- /** has killed in Yarn */
+
+ /** Has killed in Yarn. */
KILLED(-9);
private final int value;
diff --git
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/GitAuthorizedError.java
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/GitAuthorizedError.java
index 9856bacaf..04d4d4e5e 100644
---
a/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/GitAuthorizedError.java
+++
b/streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/enums/GitAuthorizedError.java
@@ -21,16 +21,16 @@ import java.io.Serializable;
public enum GitAuthorizedError implements Serializable {
- /** success */
+ /** Success. */
SUCCESS(0),
- /** need required, user password is null */
+ /** Need required, user password is null. */
REQUIRED(1),
- /** user password error */
+ /** User password error. */
ERROR(2),
- /** 其他未知错误 */
+ /** Unknown error. */
UNKNOW(3);
private final int value;