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/01/11 17:50:56 UTC
[1/3] storm git commit: [STORM-1499] Fix Kafka spout to maintain
backward compatibility
Repository: storm
Updated Branches:
refs/heads/master b90941894 -> 24f03e570
[STORM-1499] Fix Kafka spout to maintain backward compatibility
STORM-1220 introduced some changes where in one place it passes ByteBuffer as is instead of byte[].
Existing bolts (0.10.0) expects a byte[] and fails with
"java.lang.RuntimeException: java.lang.ClassCastException: java.nio.HeapByteBuffer cannot be cast to [B "
This patch addresses the issue by emiting byte[] instead of ByteBuffer.
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1eca8a33
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1eca8a33
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1eca8a33
Branch: refs/heads/master
Commit: 1eca8a3398679dce7675e72d91527ac05335bd54
Parents: ce31f4c
Author: Arun Mahadevan <ai...@hortonworks.com>
Authored: Thu Jan 7 15:26:00 2016 +0530
Committer: Arun Mahadevan <ai...@hortonworks.com>
Committed: Thu Jan 7 15:26:00 2016 +0530
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/spout/RawMultiScheme.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/1eca8a33/storm-core/src/jvm/backtype/storm/spout/RawMultiScheme.java
----------------------------------------------------------------------
diff --git a/storm-core/src/jvm/backtype/storm/spout/RawMultiScheme.java b/storm-core/src/jvm/backtype/storm/spout/RawMultiScheme.java
index 824d16c..48999fc 100644
--- a/storm-core/src/jvm/backtype/storm/spout/RawMultiScheme.java
+++ b/storm-core/src/jvm/backtype/storm/spout/RawMultiScheme.java
@@ -21,6 +21,7 @@ import java.nio.ByteBuffer;
import java.util.List;
import backtype.storm.tuple.Fields;
+import backtype.storm.utils.Utils;
import static backtype.storm.utils.Utils.tuple;
@@ -29,7 +30,7 @@ import static java.util.Arrays.asList;
public class RawMultiScheme implements MultiScheme {
@Override
public Iterable<List<Object>> deserialize(ByteBuffer ser) {
- return asList(tuple(ser));
+ return asList(tuple(Utils.toByteArray(ser)));
}
@Override
[3/3] storm git commit: Added STORM-1449 to Chagelog
Posted by bo...@apache.org.
Added STORM-1449 to Chagelog
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/24f03e57
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/24f03e57
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/24f03e57
Branch: refs/heads/master
Commit: 24f03e5702fd46dba6a48796e66112362f0ad425
Parents: 17732a3
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Mon Jan 11 10:50:08 2016 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Mon Jan 11 10:50:08 2016 -0600
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/24f03e57/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index cb43748..e7b644c 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 0.11.0
+ * STORM-1449: Fix Kafka spout to maintain backward compatibility
* STORM-1458: Add check to see if nimbus is already running.
* STORM-1462: Upgrade HikariCP to 2.4.3
* STORM-1457: Avoid collecting pending tuples if topology.debug is off
[2/3] storm git commit: Merge branch 'STORM-1499' of
https://github.com/arunmahadevan/storm into STORM-1449
Posted by bo...@apache.org.
Merge branch 'STORM-1499' of https://github.com/arunmahadevan/storm into STORM-1449
STORM-1449: Fix Kafka spout to maintain backward compatibility
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/17732a36
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/17732a36
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/17732a36
Branch: refs/heads/master
Commit: 17732a36f68ccd0db5df5cd18194c4201abd563c
Parents: b909418 1eca8a3
Author: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Authored: Mon Jan 11 10:49:12 2016 -0600
Committer: Robert (Bobby) Evans <ev...@yahoo-inc.com>
Committed: Mon Jan 11 10:49:12 2016 -0600
----------------------------------------------------------------------
storm-core/src/jvm/backtype/storm/spout/RawMultiScheme.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------