You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2015/08/26 12:40:44 UTC
[2/4] flink git commit: [hotfix] Fixes auto type registration
settings in ExecutionConfig
[hotfix] Fixes auto type registration settings in ExecutionConfig
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7e447120
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7e447120
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7e447120
Branch: refs/heads/release-0.9
Commit: 7e447120eab3700d788a3a968392007f27773429
Parents: 3f2cf5a
Author: Till Rohrmann <tr...@apache.org>
Authored: Wed Aug 26 10:56:27 2015 +0200
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Wed Aug 26 12:39:39 2015 +0200
----------------------------------------------------------------------
.../main/java/org/apache/flink/api/common/ExecutionConfig.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/7e447120/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
index 4974295..c4b5874 100644
--- a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
+++ b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java
@@ -78,7 +78,7 @@ public class ExecutionConfig implements Serializable {
private boolean objectReuse = false;
- private boolean disableAutoTypeRegistration = false;
+ private boolean autoTypeRegistrationEnabled = true;
private boolean forceAvro = false;
@@ -558,7 +558,7 @@ public class ExecutionConfig implements Serializable {
public boolean isAutoTypeRegistrationDisabled() {
- return disableAutoTypeRegistration;
+ return !autoTypeRegistrationEnabled;
}
/**
@@ -567,7 +567,7 @@ public class ExecutionConfig implements Serializable {
*
*/
public void disableAutoTypeRegistration() {
- this.disableAutoTypeRegistration = false;
+ this.autoTypeRegistrationEnabled = false;
}