You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2020/05/17 15:39:04 UTC
[flink] 02/11: [hotfix] Fix the access modifiers in
WorkerSpecContainerResourceAdapter
This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit a06b1bb7f60d6029862677e154fc4ef80d4ae0f9
Author: Yangze Guo <ka...@gmail.com>
AuthorDate: Mon May 4 22:34:49 2020 +0800
[hotfix] Fix the access modifiers in WorkerSpecContainerResourceAdapter
---
.../org/apache/flink/yarn/WorkerSpecContainerResourceAdapter.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-yarn/src/main/java/org/apache/flink/yarn/WorkerSpecContainerResourceAdapter.java b/flink-yarn/src/main/java/org/apache/flink/yarn/WorkerSpecContainerResourceAdapter.java
index d5eada8..723e80d 100644
--- a/flink-yarn/src/main/java/org/apache/flink/yarn/WorkerSpecContainerResourceAdapter.java
+++ b/flink-yarn/src/main/java/org/apache/flink/yarn/WorkerSpecContainerResourceAdapter.java
@@ -42,7 +42,7 @@ import java.util.stream.Collectors;
/**
* Utility class for converting between Flink {@link WorkerResourceSpec} and Yarn {@link Resource}.
*/
-public class WorkerSpecContainerResourceAdapter {
+class WorkerSpecContainerResourceAdapter {
private static final Logger LOG = LoggerFactory.getLogger(WorkerSpecContainerResourceAdapter.class);
private final Configuration flinkConfig;
@@ -141,7 +141,7 @@ public class WorkerSpecContainerResourceAdapter {
return MathUtils.divideRoundUp(value, unitValue) * unitValue;
}
- boolean resourceWithinMaxAllocation(final InternalContainerResource resource) {
+ private boolean resourceWithinMaxAllocation(final InternalContainerResource resource) {
return resource.memory <= maxMemMB && resource.vcores <= maxVcore;
}