You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@kylin.apache.org by "Le Van Ha (JIRA)" <ji...@apache.org> on 2016/08/11 04:12:20 UTC

[jira] [Comment Edited] (KYLIN-1947) Kylin Cube from Streaming (Kafka) error with v1.5.3

    [ https://issues.apache.org/jira/browse/KYLIN-1947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15416512#comment-15416512 ] 

Le Van Ha edited comment on KYLIN-1947 at 8/11/16 4:11 AM:
-----------------------------------------------------------

thanks.
but when i run:
$KYLIN_HOME/bin/streaming_build.sh STREAMING_CUBE 300000 0

error: 
2016-08-11 04:06:31,364 INFO  [main TimedJsonStreamParser:98]: TimedJsonStreamParser with formatTs false tsColName order_time
Exception in thread "main" java.lang.NoSuchMethodError: kafka.cluster.Broker.<init>(ILjava/lang/String;I)V
	at org.apache.kylin.source.kafka.config.KafkaClusterConfig$1.apply(KafkaClusterConfig.java:70)
	at org.apache.kylin.source.kafka.config.KafkaClusterConfig$1.apply(KafkaClusterConfig.java:66)
	at com.google.common.collect.Lists$TransformingRandomAccessList.get(Lists.java:491)
	at java.util.AbstractList$Itr.next(AbstractList.java:358)
	at org.apache.kylin.source.kafka.util.KafkaRequester.getKafkaTopicMeta(KafkaRequester.java:100)
	at org.apache.kylin.source.kafka.KafkaStreamingInput.getBatchWithTimeWindow(KafkaStreamingInput.java:110)
	at org.apache.kylin.engine.streaming.OneOffStreamingBuilder$1.run(OneOffStreamingBuilder.java:75)
	at org.apache.kylin.engine.streaming.cli.StreamingCLI.startOneOffCubeStreaming(StreamingCLI.java:123)
	at org.apache.kylin.engine.streaming.cli.StreamingCLI.main(StreamingCLI.java:97)

in file log of Kylin



was (Author: halevanha):
thanks.
but when i run:
$KYLIN_HOME/bin/streaming_build.sh STREAMING_CUBE 300000 0

error: 
2016-08-11 04:06:31,364 INFO  [main TimedJsonStreamParser:98]: TimedJsonStreamParser with formatTs false tsColName order_time
Exception in thread "main" java.lang.NoSuchMethodError: kafka.cluster.Broker.<init>(ILjava/lang/String;I)V
	at org.apache.kylin.source.kafka.config.KafkaClusterConfig$1.apply(KafkaClusterConfig.java:70)
	at org.apache.kylin.source.kafka.config.KafkaClusterConfig$1.apply(KafkaClusterConfig.java:66)
	at com.google.common.collect.Lists$TransformingRandomAccessList.get(Lists.java:491)
	at java.util.AbstractList$Itr.next(AbstractList.java:358)
	at org.apache.kylin.source.kafka.util.KafkaRequester.getKafkaTopicMeta(KafkaRequester.java:100)
	at org.apache.kylin.source.kafka.KafkaStreamingInput.getBatchWithTimeWindow(KafkaStreamingInput.java:110)
	at org.apache.kylin.engine.streaming.OneOffStreamingBuilder$1.run(OneOffStreamingBuilder.java:75)
	at org.apache.kylin.engine.streaming.cli.StreamingCLI.startOneOffCubeStreaming(StreamingCLI.java:123)
	at org.apache.kylin.engine.streaming.cli.StreamingCLI.main(StreamingCLI.java:97)


> Kylin Cube from Streaming (Kafka) error with v1.5.3
> ---------------------------------------------------
>
>                 Key: KYLIN-1947
>                 URL: https://issues.apache.org/jira/browse/KYLIN-1947
>             Project: Kylin
>          Issue Type: Bug
>    Affects Versions: v1.5.3
>            Reporter: Le Van Ha
>             Fix For: v1.5.3
>
>
> When I run command line:
> ./bin/kylin.sh org.apache.kylin.source.kafka.util.KafkaSampleProducer --topic kylin_demo --broker sandbox:6667 —delay 0
> error:
> Exception in thread "main" java.lang.NoClassDefFoundError: kafka/producer/ProducerConfig
>         at org.apache.kylin.source.kafka.util.KafkaSampleProducer.main(KafkaSampleProducer.java:102)
> Caused by: java.lang.ClassNotFoundException: kafka.producer.ProducerConfig
>         at java.net.URLClassLoader$1.run(URLClassLoader.java:366)
>         at java.net.URLClassLoader$1.run(URLClassLoader.java:355)
>         at java.security.AccessController.doPrivileged(Native Method)
>         at java.net.URLClassLoader.findClass(URLClassLoader.java:354)
>         at java.lang.ClassLoader.loadClass(ClassLoader.java:425)
>         at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308)
>         at java.lang.ClassLoader.loadClass(ClassLoader.java:358)
>         ... 1 more



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