Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/4639#discussion_r140454362
--- 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 --
Exactly, somebody could come up with the stupid idea to return ``this`` as
inner object. Just to be on the safe side.
---