flink git commit: [hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators

[sewen]

Repository: flink
Updated Branches:
  refs/heads/release-0.10 2d7f0b1af -> dfeee2372


[hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators

This closes #1511


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dfeee237
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dfeee237
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dfeee237

Branch: refs/heads/release-0.10
Commit: dfeee23721352544f02e3ec41234e05d95d56158
Parents: 2d7f0b1
Author: Prez Cannady 
Authored: Thu Jan 14 18:58:41 2016 -0500
Committer: Stephan Ewen 
Committed: Fri Jan 15 12:22:36 2016 +0100

--
 .../org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/flink/blob/dfeee237/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
--
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
index b813153..d0f4bad 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
@@ -71,7 +71,7 @@ public class AccumulatorSnapshot implements Serializable {
 * @return the serialized map
 */
public Map 
deserializeFlinkAccumulators() throws IOException, ClassNotFoundException {
-   return 
flinkAccumulators.deserializeValue(ClassLoader.getSystemClassLoader());
+   return 
flinkAccumulators.deserializeValue(getClass().getClassLoader());
}
 
/**

flink git commit: [hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators

[sewen]

Repository: flink
Updated Branches:
  refs/heads/master 2c556f74e -> cfcb5d7ba


[hotfix] Use AccumulatorSnapshot's class loader for deserializing accumulators

This closes #1511


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cfcb5d7b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cfcb5d7b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cfcb5d7b

Branch: refs/heads/master
Commit: cfcb5d7ba5c22295c0ae628f8d9a2447e2286985
Parents: 2c556f7
Author: Prez Cannady 
Authored: Thu Jan 14 18:58:41 2016 -0500
Committer: Stephan Ewen 
Committed: Fri Jan 15 12:23:42 2016 +0100

--
 .../org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/flink/blob/cfcb5d7b/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
--
diff --git 
a/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
 
b/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
index b813153..d0f4bad 100644
--- 
a/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
+++ 
b/flink-runtime/src/main/java/org/apache/flink/runtime/accumulators/AccumulatorSnapshot.java
@@ -71,7 +71,7 @@ public class AccumulatorSnapshot implements Serializable {
 * @return the serialized map
 */
public Map 
deserializeFlinkAccumulators() throws IOException, ClassNotFoundException {
-   return 
flinkAccumulators.deserializeValue(ClassLoader.getSystemClassLoader());
+   return 
flinkAccumulators.deserializeValue(getClass().getClassLoader());
}
 
/**