[hotfix] Fix SimpleStringSchema serialization issue

nltran · Nov 28, 2015 · e9a2bc9 · e9a2bc9
1 parent 09ea3dd
commit e9a2bc9
Showing 1 changed file with 2 additions and 14 deletions.
diff --git a/...-java/src/main/java/org/apache/flink/streaming/util/serialization/SimpleStringSchema.java b/...-java/src/main/java/org/apache/flink/streaming/util/serialization/SimpleStringSchema.java
@@ -20,8 +20,6 @@
 import org.apache.flink.api.common.typeinfo.BasicTypeInfo;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 
-import java.nio.charset.Charset;
-
 /**
  * Very simple serialization schema for strings.
  */
@@ -30,19 +28,9 @@ public class SimpleStringSchema implements DeserializationSchema<String>,
 
  private static final long serialVersionUID = 1L;
 
- private Charset charset = Charset.defaultCharset();
-
- public SimpleStringSchema() {
-
- }
-
- public SimpleStringSchema(Charset charset) {
- this.charset = charset;
- }
-
  @Override
  public String deserialize(byte[] message) {
- return new String(message, charset);
+ return new String(message);
  }
 
  @Override
@@ -52,7 +40,7 @@ public boolean isEndOfStream(String nextElement) {
 
  @Override
  public byte[] serialize(String element) {
- return element.getBytes(charset);
+ return element.getBytes();
  }
 
  @Override