Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/4671
---
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4671#discussion_r140458205
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/async/AbstractAsyncCallableWithResources.java
---
@@ -0,0 +1,194 @@
+/*
+ *
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4671#discussion_r140458424
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/async/AbstractAsyncCallableWithResources.java
---
@@ -0,0 +1,194 @@
+/*
+ *
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4671#discussion_r140456968
--- Diff:
flink-core/src/main/java/org/apache/flink/util/AbstractCloseableRegistry.java
---
@@ -90,14 +90,14 @@ public final void registerClosable(C
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4671#discussion_r140458159
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/async/AbstractAsyncCallableWithResources.java
---
@@ -0,0 +1,194 @@
+/*
+ *
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/4671
[FLINK-7619] Improve abstraction in AbstractAsyncIOCallable to better fit
## What is the purpose of the change
This PR improves the abstractions around resource management for async
