aloyszhang commented on code in PR #11130:
URL: https://github.com/apache/inlong/pull/11130#discussion_r1772460241
##########
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/Constants.java:
##########
@@ -67,6 +67,20 @@ public final class Constants {
public static final String CURRENT_EMIT_EVENT_TIME_LAG =
"currentEmitEventTimeLag";
+ public static final String DESERIALIZE_TIME_LAG = "deserializeTimeLag";
+
+ public static final String NUM_DESERIALIZE_SUCCESS =
"numDeserializeSuccess";
+
+ public static final String NUM_DESERIALIZE_ERROR = "numDeserializeError";
+
+ public static final String NUM_SNAPSHOT_CREATE = "numSnapshotCreate";
+
+ public static final String NUM_SNAPSHOT_ERROR = "numSnapshotError";
+
+ public static final String NUM_COMPLETED_SNAPSHOTS =
"numCompletedSnapshots";
Review Comment:
```suggestion
public static final String NUM_SNAPSHOT_COMPLETE = "numSnapshotComplete";
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
