Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6071#discussion_r194663296
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/router/RoutedRequest.java
---
@@ -97,11 +98,17 @@ public ReferenceCounted retain(int arg0) {
@Override
public ReferenceCounted touch() {
+ if (requestAsReferenceCounted.isPresent()) {
+
ReferenceCountUtil.touch(requestAsReferenceCounted.get());
+ }
return this;
}
@Override
public ReferenceCounted touch(Object o) {
+ if (requestAsReferenceCounted.isPresent()) {
+
ReferenceCountUtil.touch(requestAsReferenceCounted.get());
--- End diff --
Shall we pass `o` to the `ReferenceCountUtil.touch` call?
---
