You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2015/11/28 10:28:57 UTC
flink git commit: [hotfix] Fix SimpleStringSchema serialization issue
Repository: flink
Updated Branches:
refs/heads/master 09ea3dd0f -> e9a2bc9d0
[hotfix] Fix SimpleStringSchema serialization issue
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e9a2bc9d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e9a2bc9d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e9a2bc9d
Branch: refs/heads/master
Commit: e9a2bc9d0467a8b0f61caab1b36b2f738f8bfc0e
Parents: 09ea3dd
Author: Robert Metzger <rm...@apache.org>
Authored: Sat Nov 28 08:49:05 2015 +0100
Committer: Robert Metzger <rm...@apache.org>
Committed: Sat Nov 28 10:27:53 2015 +0100
----------------------------------------------------------------------
.../util/serialization/SimpleStringSchema.java | 16 ++--------------
1 file changed, 2 insertions(+), 14 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/e9a2bc9d/flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/SimpleStringSchema.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/SimpleStringSchema.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/SimpleStringSchema.java
index 2c6457d..ca498c0 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/SimpleStringSchema.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/util/serialization/SimpleStringSchema.java
@@ -20,8 +20,6 @@ package org.apache.flink.streaming.util.serialization;
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 class SimpleStringSchema implements DeserializationSchema<String>,
@Override
public byte[] serialize(String element) {
- return element.getBytes(charset);
+ return element.getBytes();
}
@Override