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 0a9db1e [FLINK-14466][runtime] Let YarnJobClusterEntrypoint use user
code class loader
add cb62c5f [hotfix] Refactor TaskExecutorTest.testTaskSubmission to not
use mocking
add d3ecd3d [hotfix] Introduce TaskSlotUtils for tests
add 01d6972 [hotfix] Refactor out slots creation from the TaskSlotTable
constructor
add 9fed0dd [FLINK-14400] Shrink the scope of MemoryManager from
TaskExecutor to slot
add 4c4652e [hotfix] Remove unused number of slots in MemoryManager
add 48986aa [hotfix] Remove unnecessary comments about memory size
calculation before network init
add ad531f0 [hotfix] Remove redundant timerService in TaskExecutorTest
No new revisions were added by this update.
Summary of changes:
.../apache/flink/runtime/memory/MemoryManager.java | 16 +-
.../flink/runtime/taskexecutor/TaskExecutor.java | 15 +-
.../runtime/taskexecutor/TaskManagerServices.java | 88 ++++++-----
.../flink/runtime/taskexecutor/slot/TaskSlot.java | 39 ++++-
.../runtime/taskexecutor/slot/TaskSlotTable.java | 43 ++++--
.../flink/runtime/memory/MemoryManagerBuilder.java | 8 +-
.../TaskExecutorPartitionLifecycleTest.java | 8 +-
.../runtime/taskexecutor/TaskExecutorTest.java | 164 +++++++--------------
.../taskexecutor/TaskManagerServicesBuilder.java | 14 +-
.../TaskSubmissionTestEnvironment.java | 13 +-
.../taskexecutor/slot/TaskSlotTableTest.java | 19 +--
.../runtime/taskexecutor/slot/TaskSlotUtils.java | 77 ++++++++++
.../operators/aggregate/BytesHashMapTest.java | 6 -
13 files changed, 268 insertions(+), 242 deletions(-)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotUtils.java
