[
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)
