diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/Text.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/Text.java index 67d7c4f234..3ab327fe76 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/Text.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/Text.java @@ -203,19 +203,10 @@ public void set(String string) { } } - /** - * Set to a utf8 byte array. If the length of utf8 is - * zero, actually clear {@link #bytes} and any existing - * data is lost. + /** Set to a utf8 byte array */ public void set(byte[] utf8) { - if (utf8.length == 0) { - bytes = EMPTY_BYTES; - length = 0; - textLength = -1; - } else { - set(utf8, 0, utf8.length); - } + set(utf8, 0, utf8.length); } /** copy a text. */ diff --git a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/TestText.java b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/TestText.java index 715afaf176..0fb20acf4c 100644 --- a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/TestText.java +++ b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/io/TestText.java @@ -449,22 +449,4 @@ public void testUtf8Length() { 2, Text.utf8Length(new String(new char[]{(char)254}))); } - @Test - public void testSetBytes(){ - Text a = new Text(new byte[100]); - assertEquals("testSetBytes100 getLength error !", - 100, a.getLength()); - assertEquals("testSetBytes100 getBytes.length error !", - 100, a.getBytes().length); - assertEquals("testSetBytes100 getTextLength error !", - 100, a.getTextLength()); - - a.set(new byte[0]); - assertEquals("testSetBytes0 getLength error !", - 0, a.getLength()); - assertEquals("testSetBytes0 getBytes.length error !", - 0, a.getBytes().length); - assertEquals("testSetBytes0 getTextLength error !", - 0, a.getTextLength()); - } }