You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@streampark.apache.org by "ChengJie1053 (via GitHub)" <gi...@apache.org> on 2023/09/13 01:21:53 UTC

[GitHub] [incubator-streampark] ChengJie1053 commented on pull request #3048: [Feat][Flink-K8s-V2] Adaptation of snapshot tracking for Flink on Kubernetes

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: issues-unsubscribe@streampark.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org