Hi??
I want to restart custom topic from begining??so I change the
cubeDescr??But a issue occured??
org.apache.kylin.engine.mr.exception.MapReduceException: Counters: 13 Job
Counters Failed map tasks=10 Killed map tasks=2
Launched map tasks=12 Other local map tasks=9
Rack-local map tasks=3 Total time spent by all maps in occupied slots
(ms)=1537870 Total time spent by all reduces in occupied slots
(ms)=0 Total time spent by all map tasks (ms)=768935
Total vcore-milliseconds taken by all map tasks=768935 Total
megabyte-milliseconds taken by all map tasks=787389440 Map-Reduce Framework
CPU time spent (ms)=0 Physical memory (bytes) snapshot=0
Virtual memory (bytes) snapshot=0 Job Diagnostics:Task failed
task_1560134077922_0358_m_000002 Job failed as tasks failed. failedMaps:1
failedReduces:0 Failure task Diagnostics: Error: java.io.IOException:
Unexpected ending of stream, expected ending offset 416824, but end at 0 at
org.apache.kylin.source.kafka.hadoop.KafkaInputRecordReader.nextKeyValue(KafkaInputRecordReader.java:126)
at
org.apache.hadoop.mapred.MapTask$NewTrackingRecordReader.nextKeyValue(MapTask.java:556)
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:145) at
org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:787) at
org.apache.hadoop.mapred.MapTask.run(MapTask.java:341) at
org.apache.hadoop.mapred.YarnChild$2.run(YarnChild.java:170) at
java.security.AccessController.doPrivileged(Native Method) at
javax.security.auth.Subject.doAs(Subject.java:422) at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1869)
at org.apache.hadoop.mapred.YarnChild.main(YarnChild.java:164)
Container killed by the ApplicationMaster. Container killed on request. Exit
code is 143 Container exited with a non-zero exit code 143. at
org.apache.kylin.engine.mr.common.MapReduceExecutable.doWork(MapReduceExecutable.java:173)
at
org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:168)
at
org.apache.kylin.job.execution.DefaultChainedExecutable.doWork(DefaultChainedExecutable.java:71)
at
org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:168)
at
org.apache.kylin.job.impl.threadpool.DefaultScheduler$JobRunner.run(DefaultScheduler.java:114)
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)
