[
https://issues.apache.org/jira/browse/STORM-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15107941#comment-15107941
]
ASF GitHub Bot commented on STORM-1449:
---------------------------------------
Github user arunmahadevan commented on the pull request:
https://github.com/apache/storm/pull/994#issuecomment-173077993
@priyank5485 @revans2 @Parth-Brahmbhatt the changes introduced by
STORM-1220 has not yet gone out in any releases. It will go out in 1.0 but with
the fix in this PR (which is also part of 1.0) the changes are backward
compatible. i.e. the KafkaSpout would emit byte[] and not ByteBuffer as values
in the tuples. So the old bolts (that expects a byte[]) would continue to work
with the new KafkaSpout.
I assume @priyank5485 got the issue when the jar was built from master
branch before this PR got merged in and got bundled with the client.
Correct me if I am missing something.
> Fix Kafka spout to maintain backward compatibility to pass byte[] instead of
> ByteBuffer
> ---------------------------------------------------------------------------------------
>
> Key: STORM-1449
> URL: https://issues.apache.org/jira/browse/STORM-1449
> Project: Apache Storm
> Issue Type: Bug
> Reporter: Arun Mahadevan
> Assignee: Arun Mahadevan
> Fix For: 1.0.0
>
>
> STORM-1220 introduced some changes where in one place it passes ByteBuffer as
> is instead of byte[]. Existing bolts that expects a byte[] fails due to this
> with "java.lang.RuntimeException: java.lang.ClassCastException:
> java.nio.HeapByteBuffer cannot be cast to [B "
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
