You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2014/11/06 12:58:29 UTC
[2/2] git commit: [FLINK-1005] By default,
new objects are created for each element in group operations
[FLINK-1005] By default, new objects are created for each element in group operations
Project: http://git-wip-us.apache.org/repos/asf/incubator-flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-flink/commit/a586614a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-flink/tree/a586614a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-flink/diff/a586614a
Branch: refs/heads/master
Commit: a586614aea9a639efcb096797dd7aa68306f8af4
Parents: c3835cd
Author: Stephan Ewen <se...@apache.org>
Authored: Wed Nov 5 12:19:24 2014 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Wed Nov 5 15:25:56 2014 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/runtime/operators/util/TaskConfig.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/a586614a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/TaskConfig.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/TaskConfig.java b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/TaskConfig.java
index eba5319..1b44a3b 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/TaskConfig.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/operators/util/TaskConfig.java
@@ -344,7 +344,7 @@ public class TaskConfig {
}
public boolean getMutableObjectMode() {
- return this.config.getBoolean(DRIVER_MUTABLE_OBJECT_MODE, true);
+ return this.config.getBoolean(DRIVER_MUTABLE_OBJECT_MODE, false);
}
public void setDriverComparator(TypeComparatorFactory<?> factory, int inputNum) {