You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2018/06/14 23:49:34 UTC

[7/7] flink git commit: [hotfix] Remove duplicate lines

[hotfix] Remove duplicate lines


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

Branch: refs/heads/master
Commit: 009e9fe4e9a24ccad949d75d745f9a1d8cf3ae98
Parents: 0dc0e36
Author: zentol <ch...@apache.org>
Authored: Thu Jun 14 23:15:48 2018 +0200
Committer: zentol <ch...@apache.org>
Committed: Thu Jun 14 23:15:48 2018 +0200

----------------------------------------------------------------------
 .../src/main/java/org/apache/flink/orc/OrcRowInputFormat.java       | 1 -
 flink-core/src/main/java/org/apache/flink/types/StringValue.java    | 1 -
 2 files changed, 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/009e9fe4/flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java b/flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
index 08c1164..ae28194 100644
--- a/flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
+++ b/flink-connectors/flink-orc/src/main/java/org/apache/flink/orc/OrcRowInputFormat.java
@@ -304,7 +304,6 @@ public class OrcRowInputFormat extends FileInputFormat<Row> implements ResultTyp
 	@Override
 	public void closeInputFormat() throws IOException {
 		this.rows = null;
-		this.rows = null;
 		this.schema = null;
 		this.rowBatch = null;
 	}

http://git-wip-us.apache.org/repos/asf/flink/blob/009e9fe4/flink-core/src/main/java/org/apache/flink/types/StringValue.java
----------------------------------------------------------------------
diff --git a/flink-core/src/main/java/org/apache/flink/types/StringValue.java b/flink-core/src/main/java/org/apache/flink/types/StringValue.java
index 382bc17..feeec2a 100644
--- a/flink-core/src/main/java/org/apache/flink/types/StringValue.java
+++ b/flink-core/src/main/java/org/apache/flink/types/StringValue.java
@@ -192,7 +192,6 @@ public class StringValue implements NormalizableKey<StringValue>, CharSequence,
 		for (int i = 0; i < len; i++) {
 			this.value[i] = value.charAt(offset + i);
 		}
-		this.len = len;
 		this.hashCode = 0;
 	}