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 fc619df9b520e33c332d39a34ea05bdc3ec3f4df Author: Weijie Guo <[email protected]> AuthorDate: Tue Jul 26 20:34:58 2022 +0800 [hotfix] Make HsMemoryDataManager runWithLockMethod private. --- .../flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java index 0a7c60cf9b2..b58338b6912 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/HsMemoryDataManager.java @@ -255,7 +255,7 @@ public class HsMemoryDataManager implements HsSpillingInfoProvider, HsMemoryData bufferPool.recycle(buffer); } - public <T, R extends Exception> T callWithLock(SupplierWithException<T, R> callable) throws R { + private <T, R extends Exception> T callWithLock(SupplierWithException<T, R> callable) throws R { try { lock.lock(); return callable.get();
