Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5193#discussion_r158397131
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/operators/testutils/TaskTestBase.java
---
@@ -145,19 +145,7 @@ public MemoryManager getMemoryManager() {
}
@After
- public void shutdownIOManager() throws Exception {
- this.mockEnv.getIOManager().shutdown();
- Assert.assertTrue("IO Manager has not properly shut down.",
this.mockEnv.getIOManager().isProperlyShutDown());
- }
-
- @After
- public void shutdownMemoryManager() throws Exception {
- if (this.memorySize > 0) {
--- End diff --
This memory size pre-check was lost in translation after the refactoring.
Not sure if that matters, though.
---
