[jira] [Commented] (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=15416540#comment-15416540 ] Shaofeng SHI commented on KYLIN-1947: - what's your kafka version? Kylin is compiled with kafka 0.8 API. > 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)
[jira] [Commented] (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=15416512#comment-15416512 ] Le Van Ha commented on KYLIN-1947: -- thanks. but when i run: $KYLIN_HOME/bin/streaming_build.sh STREAMING_CUBE 30 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.(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)
[jira] [Commented] (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=15412943#comment-15412943 ] Shaofeng SHI commented on KYLIN-1947: - This is the same issue as https://issues.apache.org/jira/browse/KYLIN-1871 The reason is from v1.5.3, Kylin doesn't embed kafka client jar anymore; User need copy the kafka (0.8) client jar to Kylin's lib folder, please take a try. > 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)
