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)

Reply via email to