Jiaming Lin created STORM-1728:
----------------------------------
Summary: TransactionalTridentKafkaSpout error
Key: STORM-1728
URL: https://issues.apache.org/jira/browse/STORM-1728
Project: Apache Storm
Issue Type: Bug
Components: storm-kafka, trident
Affects Versions: 1.0.0
Environment: <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>
Reporter: Jiaming Lin
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.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)