Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4639#discussion_r140449401
--- Diff:
flink-core/src/main/java/org/apache/flink/util/WrappingProxyUtil.java ---
@@ -27,10 +27,16 @@ private WrappingProxyUtil() {
throw new AssertionError();
}
+ @SuppressWarnings("unchecked")
public static <T> T stripProxy(T object) {
- while (object instanceof WrappingProxy) {
+
+ T previous = null;
+
+ while (object instanceof WrappingProxy && previous != object) {
--- End diff --
Guarding against infinite looping in case the bottom-most object is also a
`WrappingProxy`?
---
