kylin-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 忧郁的风 <zsh...@126.com>
Subject Kylin consume Kafka error,help
Date Thu, 22 Aug 2019 10:16:58 GMT
Hello everyone.
  i found a error when using kylin consume kafka.
my stream source config table:


kafka message format:
{"user_id":35053871,"event_type":0,"goods_id":598854056706,"goods_name":"南瓜谷风衣女中长款2019秋季新款韩版宽松小个子流行大衣外套F017","goods_original_price":0.0,"goods_price":0.0,"goods_coupon_value":0.0,"action_time":"2019-08-19
23:30:03"}


cube config:


Error Occurring when build cube, error message:


java.lang.IllegalArgumentException: java.lang.reflect.InvocationTargetException
at org.apache.kylin.source.kafka.KafkaMRInput$KafkaTableInputFormat.<init>(KafkaMRInput.java:108)
at org.apache.kylin.source.kafka.KafkaMRInput$BatchCubingInputSide.getFlatTableInputFormat(KafkaMRInput.java:191)
at org.apache.kylin.engine.mr.steps.FactDistinctColumnsJob.setupMapper(FactDistinctColumnsJob.java:140)
at org.apache.kylin.engine.mr.steps.FactDistinctColumnsJob.run(FactDistinctColumnsJob.java:119)
at org.apache.kylin.engine.mr.MRUtil.runMRJob(MRUtil.java:92)
at org.apache.kylin.engine.mr.common.MapReduceExecutable.doWork(MapReduceExecutable.java:122)
at org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:125)
at org.apache.kylin.job.execution.DefaultChainedExecutable.doWork(DefaultChainedExecutable.java:65)
at org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:125)
at org.apache.kylin.job.impl.threadpool.DefaultScheduler$JobRunner.run(DefaultScheduler.java:141)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.reflect.InvocationTargetException
at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
at java.lang.reflect.Constructor.newInstance(Constructor.java:423)
at org.apache.kylin.source.kafka.StreamingParser.getStreamingParser(StreamingParser.java:77)
at org.apache.kylin.source.kafka.KafkaMRInput$KafkaTableInputFormat.<init>(KafkaMRInput.java:106)
... 12 more
Caused by: java.lang.IllegalStateException: Invalid StreamingConfig, tsParser org.apache.kylin.source.kafka.DateTimeParser,
parserProperties {tsParser=org.apache.kylin.source.kafka.DateTimeParser, tsPattern=yyyy-MM-dd
HH:mm:ss, separator=_, tsColName=action_time}.
at org.apache.kylin.source.kafka.TimedJsonStreamParser.<init>(TimedJsonStreamParser.java:91)
... 18 more
Caused by: java.lang.ClassNotFoundException: org.apache.kylin.source.kafka.DateTimeParser
at org.apache.catalina.loader.WebappClassLoaderBase.loadClass(WebappClassLoaderBase.java:1858)
at org.apache.catalina.loader.WebappClassLoaderBase.loadClass(WebappClassLoaderBase.java:1701)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:264)
at org.apache.kylin.source.kafka.TimedJsonStreamParser.<init>(TimedJsonStreamParser.java:87)
... 18 more


my kylin version is apache-kylin-2.1.0-bin-cdh57. Please help me to see it, thanks.

Mime
View raw message