[jira] [Resolved] (KYLIN-2142) error while building the Streaming Cube.

["Shaofeng SHI (JIRA)" <ji...@apache.org>]

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

Shaofeng SHI resolved KYLIN-2142.
---------------------------------
    Resolution: Won't Fix

> error while building the Streaming Cube.
> ----------------------------------------
>
>                 Key: KYLIN-2142
>                 URL: https://issues.apache.org/jira/browse/KYLIN-2142
>             Project: Kylin
>          Issue Type: Bug
>          Components: streaming
>    Affects Versions: v1.5.4.1
>         Environment: HDP 2.4, Kafka 0.9, kylin : 1.5.4.1
>            Reporter: Bhanuprakash
>
> hi all,
> error while building the Streaming Cube.
> Environmental Details 
> *****HDP 2.4 sandbox
> *****Kylin : 1.5.4.2
> *****kafka : 0.9
> i have followed the URL for building the streaming cube in Kylin 
> 1) i have successfully created the kafka topic.
> 2) i have successfully integrated the kafka topic with kylin streaming data.
> 3) i am able to view the kafka broker sending the messages per 2 seconds and can see the data .
> 4) i have created the Streaming DB and took Order_time as partitioner.
> 5) i have executed the build command for streaming cube.
> 6) i have already google for this issue and i found below URL nd i tried copying the kafka client jars to Kylin lib folder and started to build the new streaming cube but still it has failed with the same issue.
> ( https://www.mail-archive.com/issues@kylin.apache.org/msg04708.html )
> when i see the log i see below error log
> 2016-10-29 16:55:30,894 INFO  [main TimedJsonStreamParser:97]: 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:575)
>         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:100)
>         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)
> 2016-10-29 16:55:31,125 INFO  [Thread-0 ConnectionManager$HConnectionImplementation:1683]: Closing zookeeper sessionid=0x1580fec18c0002f
> 2016-10-29 16:55:31,181 INFO  [Thread-0 ZooKeeper:684]: Session: 0x1580fec18c0002f closed
> 2016-10-29 16:55:31,185 INFO  [main-EventThread ClientCnxn:524]: EventThread shut down



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