yunqingmoswu commented on code in PR #6937:
URL: https://github.com/apache/inlong/pull/6937#discussion_r1051745054
##########
inlong-manager/manager-plugins/src/main/java/org/apache/inlong/manager/plugin/flink/enums/Constants.java:
##########
@@ -69,4 +80,27 @@ public class Constants {
public static final String SEPARATOR = ":";
+ /**
+ * Generate the Job name through {@link ProcessForm}: <br/>
+ * When the ProcessForm is {@link GroupResourceProcessForm}, the format of
the job name is 'InLong-Sort-{Group ID}-{Stream ID}',
+ * otherwise take the {@link Constants#DEFAULT_SORT_JOB_NAME}:
'InLong-Sort-Job'.
+ */
+ public static Function<ProcessForm, String> SORT_JOB_NAME_GENERATOR =
(ProcessForm processForm) -> {
Review Comment:
The inlong group is already a unique identifier, so there is no need to
generate a job name based on the stream?
--
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]
