mxm commented on PR #549: URL: https://github.com/apache/flink-kubernetes-operator/pull/549#issuecomment-1477998088
The logic was implemented in the global context because it handles logic across pipelines, something which the pipeline-specific ScalingExecutor cannot do. The logic can be used independently of the autoscaler implementation. I tried to implement the logic in the autoscaler directly but the the current design of operator / autoscaler doesn't easily allow this because the autoscaler logic is pipeline-specific without state across pipelines. If you have any ideas, please let me know. -- 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]
