Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5567
---
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5567#discussion_r171214451
--- Diff:
flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java ---
@@ -113,18 +113,61 @@ public ClassLoaderObjectInputStream(InputStream
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5567#discussion_r171212166
--- Diff:
flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java ---
@@ -113,18 +113,61 @@ public ClassLoaderObjectInputStream(InputStream
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/5567#discussion_r170247807
--- Diff:
flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java ---
@@ -121,10 +121,53 @@ public ClassLoaderObjectInputStream(InputStream
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/5567#discussion_r170231102
--- Diff:
flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java ---
@@ -121,10 +121,53 @@ public ClassLoaderObjectInputStream(InputStream
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5567#discussion_r170215340
--- Diff:
flink-core/src/main/java/org/apache/flink/util/InstantiationUtil.java ---
@@ -121,10 +121,53 @@ public ClassLoaderObjectInputStream(InputStream in,
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/5567
[FLINK-8451] [serializers] Make Scala tuple serializer deserialization more
failure tolerant
## What is the purpose of the change
Scala tuples (and thus also case classes) classes are
