Sandesh created APEXCORE-315:
--------------------------------
Summary: 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)
