You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by xt...@apache.org on 2021/07/05 03:04:11 UTC
[flink] 01/07: [hotfix][core] Fix typo in the Builder of
ResourceSpec
This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit d0846bbc8de210eb84cd1dd7469b27cf2f319f95
Author: Yangze Guo <ka...@gmail.com>
AuthorDate: Wed Jun 30 19:21:56 2021 +0800
[hotfix][core] Fix typo in the Builder of ResourceSpec
---
.../main/java/org/apache/flink/api/common/operators/ResourceSpec.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java b/flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java
index 218a70f..f66f2a3 100755
--- a/flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/operators/ResourceSpec.java
@@ -359,7 +359,7 @@ public final class ResourceSpec implements Serializable {
return this;
}
- public Builder setOffTaskHeapMemoryMB(int taskOffHeapMemoryMB) {
+ public Builder setTaskOffHeapMemoryMB(int taskOffHeapMemoryMB) {
this.taskOffHeapMemory = MemorySize.ofMebiBytes(taskOffHeapMemoryMB);
return this;
}