I follow the tutorial build a streaming cube, the partitions of the topic is 1
1??I test the blow resuful api, the result is
{"result":"success","offsets":"{0=172400}"}, but how can i use this result?curl
-X PUT --user ADMIN:KYLIN -H "Content-Type: application/json;charset=utf-8" -d
'{ "sourceOffsetStart": 0, "sourceOffsetEnd": 9223372036854775807, "buildType":
"BUILD"}'
http://localhost:7070/kylin/api/cubes/{your_cube_name}/init_start_offsets
2??in the middle of build cube??i alter the topic partitions to 2??the cube
build error??Can not i alter the partitions of the topic??
The error message is??
java.lang.IllegalArgumentException: partition number mismatch with server side
at com.google.common.base.Preconditions.checkArgument(Preconditions.java:92)
at
org.apache.kylin.source.kafka.hadoop.KafkaInputFormat.getSplits(KafkaInputFormat.java:71)
at
org.apache.hadoop.mapreduce.JobSubmitter.writeNewSplits(JobSubmitter.java:301)
at
org.apache.hadoop.mapreduce.JobSubmitter.writeSplits(JobSubmitter.java:318) at
org.apache.hadoop.mapreduce.JobSubmitter.submitJobInternal(JobSubmitter.java:196)
at org.apache.hadoop.mapreduce.Job$10.run(Job.java:1290) at
org.apache.hadoop.mapreduce.Job$10.run(Job.java:1287) 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:1657)
at org.apache.hadoop.mapreduce.Job.submit(Job.java:1287) at
org.apache.kylin.engine.mr.common.AbstractHadoopJob.waitForCompletion(AbstractHadoopJob.java:149)
at
org.apache.kylin.source.kafka.hadoop.KafkaFlatTableJob.run(KafkaFlatTableJob.java:122)
at org.apache.kylin.engine.mr.MRUtil.runMRJob(MRUtil.java:92) at
org.apache.kylin.engine.mr.common.MapReduceExecutable.doWork(MapReduceExecutable.java:120)
at
org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:113)
at
org.apache.kylin.job.execution.DefaultChainedExecutable.doWork(DefaultChainedExecutable.java:57)
at
org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:113)
at
org.apache.kylin.job.impl.threadpool.DefaultScheduler$JobRunner.run(DefaultScheduler.java:136)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745) result code:2
