apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Siyuan Hua (JIRA)" <j...@apache.org>
Subject [jira] [Closed] (APEXCORE-315) KafkaInput operator throwing exception in localMode
Date Tue, 26 Jan 2016 00:29:39 GMT

     [ https://issues.apache.org/jira/browse/APEXCORE-315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Siyuan Hua closed APEXCORE-315.
-------------------------------
    Resolution: Invalid

It a malhar issue. 

> KafkaInput operator throwing exception in localMode
> ---------------------------------------------------
>
>                 Key: APEXCORE-315
>                 URL: https://issues.apache.org/jira/browse/APEXCORE-315
>             Project: Apache Apex Core
>          Issue Type: Bug
>            Reporter: Sandesh
>            Assignee: Siyuan Hua
>
> Running the Kafka input operator in local mode is throwing "kyro class not found exception"
> com.esotericsoftware.kryo.KryoException: Unable to find class: com.datatorrent.contrib.kafka.SimpleKafkaConsumer
> Serialization trace:
> consumer (com.datatorrent.contrib.kafka.KafkaSinglePortStringInputOperator)
> at com.esotericsoftware.kryo.util.DefaultClassResolver.readName(DefaultClassResolver.java:138)
> at com.esotericsoftware.kryo.util.DefaultClassResolver.readClass(DefaultClassResolver.java:115)
> at com.esotericsoftware.kryo.Kryo.readClass(Kryo.java:641)
> at com.esotericsoftware.kryo.serializers.ObjectField.read(ObjectField.java:99)
> at com.esotericsoftware.kryo.serializers.FieldSerializer.read(FieldSerializer.java:528)
> at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:657)
> at com.datatorrent.contrib.kafka.AbstractKafkaInputOperator.createPartition(AbstractKafkaInputOperator.java:588)
> at com.datatorrent.contrib.kafka.AbstractKafkaInputOperator.definePartitions(AbstractKafkaInputOperator.java:468)
> at com.datatorrent.stram.plan.physical.PhysicalPlan.initPartitioning(PhysicalPlan.java:597)
> at com.datatorrent.stram.plan.physical.PhysicalPlan.addLogicalOperator(PhysicalPlan.java:1472)
> at com.datatorrent.stram.plan.physical.PhysicalPlan.<init>(PhysicalPlan.java:340)
> at com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:341)
> at com.datatorrent.stram.StreamingContainerManager.<init>(StreamingContainerManager.java:329)
> at com.datatorrent.stram.StramLocalCluster.<init>(StramLocalCluster.java:308)
> at com.datatorrent.stram.client.StramAppLauncher.runLocal(StramAppLauncher.java:457)
> at com.datatorrent.stram.cli.DTCli$LaunchCommand.execute(DTCli.java:2056)
> at com.datatorrent.stram.cli.DTCli.launchAppPackage(DTCli.java:3450)
> at com.datatorrent.stram.cli.DTCli.access$7000(DTCli.java:106)
> at com.datatorrent.stram.cli.DTCli$LaunchCommand.execute(DTCli.java:1892)
> Sample application at : 
> https://github.com/sandeshh/streaming-benchmarks/tree/master/apex-benchmarks



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message