yunfengzhou-hub commented on code in PR #97: URL: https://github.com/apache/flink-ml/pull/97#discussion_r891145317
########## flink-ml-lib/src/main/java/org/apache/flink/ml/clustering/kmeans/KMeans.java: ########## @@ -160,6 +162,9 @@ public IterationBodyResult process( BasicTypeInfo.INT_TYPE_INFO, DenseVectorTypeInfo.INSTANCE), new SelectNearestCentroidOperator(distanceMeasure)); + centroidIdAndPoints + .getTransformation() + .declareManagedMemoryUseCaseAtOperatorScope(ManagedMemoryUseCase.OPERATOR, 64); Review Comment: The methods provided in the reference link allow us to specify the proportion of managed memory shared among all usages of `ManagedMemoryUseCase.OPERATOR`, while the `declareManagedMemoryUseCaseAtOperatorScope` method here further specifies the proportion of managed memory this operator can use among all operators that have stated that they need managed memory through invoking this method. These two are configurations at different scopes that cannot replace each other. -- 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-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org