ChengJie1053 commented on PR #3048: URL: https://github.com/apache/incubator-streampark/pull/3048#issuecomment-1716794369
> @ChengJie1053 Hi Cheng, This PR includes optimizations for your PR #2989， `FlinkK8sChangeListenerV2` has been renamed to `FlinkK8sObserverBroker`. Include the following points: > > * Reduce backpressure on subscription fibers through ZStream.grouby. > * Correct the wrong way of writing SpringBoot Component in Scala. > * Move the startup behavior of the subscription fibers to the SpringBoot @PostConstruct phase, and correctly interrupt it in the @PreDestroy phase. > > See https://github.com/apache/incubator-streampark/pull/3048/files#diff-dd6f00b9a900099a456a69babc2cc806da8ebe68183511324a143cbf31723319 for more. Ok, thank you -- 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]
