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 2019/10/22 16:52:34 UTC
[flink] branch master updated (c31e44e -> 6d0a827)

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 c31e44e  [FLINK-14235][kafka,tests] Change source in at-least-once test from finite to infinite
     add 8e0b35c  [hotfix] Use MemorySegmentFactory in tests instead of HybridMemorySegment constructors
     add d154ae5  [hotfix] Minor refactoring of OperationsOnFreedSegmentTest
     add afe2161  [FLINK-13985] Use unsafe memory for managed memory
     add 6d0a827  [hotfix] KeyedBudgetManagerTest extends TestLogger

No new revisions were added by this update.

Summary of changes:
 .../flink/core/memory/HybridMemorySegment.java     | 70 ++++++++---------
 .../flink/core/memory/MemorySegmentFactory.java    | 47 ++++++------
 .../org/apache/flink/core/memory/MemoryUtils.java  | 81 ++++++++++++++++++++
 .../flink/core/memory/CrossSegmentTypeTest.java    | 51 ++++---------
 .../flink/core/memory/EndiannessAccessChecks.java  | 10 ++-
 .../HybridOffHeapDirectMemorySegmentTest.java}     | 29 ++++---
 .../memory/HybridOffHeapMemorySegmentTest.java     | 21 +----
 .../HybridOffHeapUnsafeMemorySegmentTest.java}     | 29 ++++---
 .../core/memory/HybridOnHeapMemorySegmentTest.java |  6 +-
 .../flink/core/memory/MemorySegmentChecksTest.java | 14 +---
 .../flink/core/memory/MemorySegmentTestBase.java   |  5 ++
 .../core/memory/MemorySegmentUndersizedTest.java   | 21 ++++-
 .../core/memory/OperationsOnFreedSegmentTest.java  | 89 ++++++++--------------
 .../apache/flink/runtime/memory/MemoryManager.java |  4 +-
 .../flink/runtime/util/KeyedBudgetManagerTest.java |  3 +-
 15 files changed, 254 insertions(+), 226 deletions(-)
 copy flink-core/src/{main/java/org/apache/flink/core/memory/DataInputViewStreamWrapper.java => test/java/org/apache/flink/core/memory/HybridOffHeapDirectMemorySegmentTest.java} (59%)
 copy flink-core/src/{main/java/org/apache/flink/core/memory/DataInputViewStreamWrapper.java => test/java/org/apache/flink/core/memory/HybridOffHeapUnsafeMemorySegmentTest.java} (58%)