You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by bo...@apache.org on 2016/02/23 21:32:08 UTC
[1/3] storm git commit: simple implemention for integer ser
Repository: storm
Updated Branches:
refs/heads/master 53446108b -> adfd75b00
simple implemention for integer ser
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/f7d59601
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/f7d59601
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/f7d59601
Branch: refs/heads/master
Commit: f7d59601ae54128ab9effa1baa8933d81b7e317b
Parents: 90e4f3e
Author: Xin Wang <be...@163.com>
Authored: Sat Jan 16 14:06:45 2016 +0800
Committer: Xin Wang <be...@163.com>
Committed: Sat Jan 16 14:06:45 2016 +0800
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/kafka/IntSerializer.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/f7d59601/external/storm-kafka/src/jvm/org/apache/storm/kafka/IntSerializer.java
----------------------------------------------------------------------
diff --git a/external/storm-kafka/src/jvm/org/apache/storm/kafka/IntSerializer.java b/external/storm-kafka/src/jvm/org/apache/storm/kafka/IntSerializer.java
index 75f5563..0a2937b 100644
--- a/external/storm-kafka/src/jvm/org/apache/storm/kafka/IntSerializer.java
+++ b/external/storm-kafka/src/jvm/org/apache/storm/kafka/IntSerializer.java
@@ -30,10 +30,12 @@ public class IntSerializer implements Serializer<Integer> {
@Override
public byte[] serialize(String topic, Integer val) {
- byte[] r = new byte[4];
- IntBuffer b = ByteBuffer.wrap(r).asIntBuffer();
- b.put(val);
- return r;
+ return new byte[] {
+ (byte) (val >>> 24),
+ (byte) (val >>> 16),
+ (byte) (val >>> 8),
+ val.byteValue()
+ };
}
@Override
[2/3] storm git commit: Merge branch 'STORM-1479' of
https://github.com/vesense/storm into STORM-1479
Posted by bo...@apache.org.
Merge branch 'STORM-1479' of https://github.com/vesense/storm into STORM-1479
STORM-1479: use a simple implemention for IntSerializer
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/92fbce93
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/92fbce93
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/92fbce93
Branch: refs/heads/master
Commit: 92fbce935c8481cc88d232d4eaf942304eecf8a1
Parents: 5344610 f7d5960
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Tue Feb 23 14:24:55 2016 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Tue Feb 23 14:24:55 2016 -0600
----------------------------------------------------------------------
.../src/jvm/org/apache/storm/kafka/IntSerializer.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
[3/3] storm git commit: Added STOMR-1479 to Changelog
Posted by bo...@apache.org.
Added STOMR-1479 to Changelog
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/adfd75b0
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/adfd75b0
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/adfd75b0
Branch: refs/heads/master
Commit: adfd75b000cdfa009d5a37efdb58c6c51697ab04
Parents: 92fbce9
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Tue Feb 23 14:25:20 2016 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Tue Feb 23 14:25:20 2016 -0600
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/adfd75b0/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 7d4f3d3..212cc4e 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 2.0.0
+ * STORM-1479: use a simple implemention for IntSerializer
* STORM-1255: port storm_utils.clj to java and split Time tests into its
* STORM-1566: Worker exits with error o.a.s.d.worker [ERROR] Error on initialization of server mk-worker
* STORM-1558: Utils in java breaks component page due to illegal type cast