Thanks for the update. Any feedback is welcomed. 2016-12-05 14:42 GMT+08:00 汪胜 <[email protected]>:
> I'm sorry to trouble you. I had found the reason about why the build job > failed. I wrote the wrong kafka host when I create streaming table. When I > added a broker, I wrote the host as "localhost". > > > > On 12/5/2016 11:00， 汪胜<[email protected]>wrote： > > Hello, I installed kylin1.6.0 and kafka0.10.1, and I followed the blog > "Scalable Cubing from Kafka (beta)" step by step, but the build job failed > at the first step "Save data from Kafka". The hadoop yarn log show the > below content: > > > "WARN [main] org.apache.hadoop.mapred.YarnChild: Exception running child > : java.io.IOException: Unexpected ending of stream, expected ending offset > 5689, but end at 0 > at org.apache.kylin.source.kafka.hadoop.KafkaInputRecordReader. > nextKeyValue(KafkaInputRecordReader.java:121) > at org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader. > nextKeyValue(MapTask.java:533) > at org.apache.hadoop.mapreduce.task.MapContextImpl. > nextKeyValue(MapContextImpl.java:80) > at org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context. > nextKeyValue(WrappedMapper.java:91) > at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:144) > at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764) > at org.apache.hadoop.mapred.MapTask.run(MapTask.java:340) > at org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:168) > at java.security.AccessController.doPrivileged(Native Method) > at javax.security.auth.Subject.doAs(Subject.java:415) > at org.apache.hadoop.security.UserGroupInformation.doAs( > UserGroupInformation.java:1614) > at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:163) > " > > > It's there something wrong with my kafka settings or kylin env? (The kafka > producer can send messages, and consumer can receive messages.) >
