[STORM-1728] TransactionalTridentKafkaSpout error - ASF JIRA

XML

Word

Printable

JSON

Details

Type: Bug
Status: Resolved
Priority: Major
Resolution: Fixed
Affects Version/s: 1.0.0
Fix Version/s: 2.0.0, 1.0.2, 1.1.0
Component/s: storm-kafka, trident
Labels:
- easyfix
Environment:

Hide
<dependency>
            <groupId>org.apache.storm</groupId>
            <artifactId>storm-kafka</artifactId>
            <version>1.0.0</version>
        </dependency>

        <dependency>
            <groupId>org.apache.storm</groupId>
            <artifactId>storm-core</artifactId>
            <version>1.0.0</version>
        </dependency>

Show
<dependency>             <groupId>org.apache.storm</groupId>             <artifactId>storm-kafka</artifactId>             <version>1.0.0</version>         </dependency>         <dependency>             <groupId>org.apache.storm</groupId>             <artifactId>storm-core</artifactId>             <version>1.0.0</version>         </dependency>

Epic Link:
Release Apache Storm 1.0.2

Description

In the PartitionedTridentSpoutExecutor.java, Integer is expected to return at line 52. However at line 55, it actually returns the List Class(the function is defined at line 48 in Coordinator.java), which throws a cast exception.

Attachments

Issue Links

is duplicated by

STORM-1854 Trident transactional spouts are broken in 1.0.x

Closed

relates to

STORM-1907 PartitionedTridentSpoutExecutor has incompatible types that cause ClassCastException

Resolved

links to

GitHub Pull Request #1438

Activity

People

Assignee:: Unassigned

Reporter:: Jiaming Lin

Votes:: 0 Vote for this issue

Watchers:: 3 Start watching this issue

Dates

Created:: 23/Apr/16 19:20

Updated:: 16/Jun/16 04:36

Resolved:: 24/May/16 19:47