You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by az...@apache.org on 2020/05/17 19:05:14 UTC
[flink] branch master updated (b606cba -> 4667286)

This is an automated email from the ASF dual-hosted git repository.

azagrebin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from b606cba  [FLINK-17522][tests] Add details on how to run Jepsen tests
     add 32a1b17  [FLINK-15758][MemManager] Remove KeyedBudgetManager and use AtomicLong
     add 4e304d4  [FLINK-15758][MemManager] Remove MemoryManager#AllocationRequest
     add 10c29b7  [FLINK-15758][MemManager] Release segment and its unsafe memory in GC Cleaner
     add 4667286  [hotfix] remove IntelliJ '//noinspection ...' directives from MemoryManager

No new revisions were added by this update.

Summary of changes:
 .../flink/core/memory/HybridMemorySegment.java     |  27 +-
 .../flink/core/memory/MemorySegmentFactory.java    |  17 +-
 .../org/apache/flink/core/memory/MemoryType.java   |  38 --
 .../org/apache/flink/core/memory/MemoryUtils.java  |   7 +-
 .../apache/flink/util/JavaGcCleanerWrapper.java    | 413 ++++++++++++++-------
 .../flink/core/memory/CrossSegmentTypeTest.java    |   2 +-
 .../flink/core/memory/EndiannessAccessChecks.java  |   2 +-
 .../HybridOffHeapUnsafeMemorySegmentTest.java      |   4 +-
 .../flink/core/memory/MemorySegmentChecksTest.java |   4 +-
 .../core/memory/MemorySegmentUndersizedTest.java   |   4 +-
 .../core/memory/OperationsOnFreedSegmentTest.java  |   2 +-
 .../flink/util/JavaGcCleanerWrapperTest.java       |   2 +-
 .../python/AbstractPythonFunctionOperator.java     |   6 +-
 .../apache/flink/runtime/memory/MemoryManager.java | 412 +++++---------------
 .../flink/runtime/memory/UnsafeMemoryBudget.java   | 183 +++++++++
 .../flink/runtime/taskexecutor/slot/TaskSlot.java  |   6 +-
 .../flink/runtime/util/KeyedBudgetManager.java     | 294 ---------------
 .../flink/runtime/memory/MemoryManagerBuilder.java |  19 +-
 .../memory/MemoryManagerSharedResourcesTest.java   |  10 +-
 .../flink/runtime/memory/MemoryManagerTest.java    | 164 ++++----
 .../runtime/memory/UnsafeMemoryBudgetTest.java     |  85 +++++
 .../operators/testutils/MockEnvironment.java       |   2 -
 .../testutils/MockEnvironmentBuilder.java          |   3 +-
 .../flink/runtime/util/KeyedBudgetManagerTest.java | 262 -------------
 .../runtime/tasks/StreamMockEnvironment.java       |   3 +-
 25 files changed, 789 insertions(+), 1182 deletions(-)
 delete mode 100644 flink-core/src/main/java/org/apache/flink/core/memory/MemoryType.java
 create mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/memory/UnsafeMemoryBudget.java
 delete mode 100644 flink-runtime/src/main/java/org/apache/flink/runtime/util/KeyedBudgetManager.java
 create mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/memory/UnsafeMemoryBudgetTest.java
 delete mode 100644 flink-runtime/src/test/java/org/apache/flink/runtime/util/KeyedBudgetManagerTest.java