aloyszhang opened a new issue, #10353: URL: https://github.com/apache/inlong/issues/10353
### Description Currently 1. the building and submission of the Flink job have duplicated code in `StartupStreamListener` and `StartupSortListener` 2. in `StartupSortListener` the process for stream exception is not consistent - if there is no valid sink configuration for a stream, this stream is skipped, and continue processing the following ones - if no dataflow for a stream, the whole process will quit directly without processing the following streams - if an exception occurs when submitted to Flink, the whole process will quit we should simplify the duplicated codes and unify the processing for exceptions for stream in `StartupSortListener`. ### InLong Component InLong Manager ### Are you willing to submit PR? - [X] Yes, I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- 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]
