kylin use the rest api to check the status of the map reduce job, and the
url used is configured by property "yarn.resourcemanager.webapp.address".
According to the log, it seems that the rest api has response, however
something goes wrong when parsing the response.
you can use the following url to check the response:
property("yarn.resourcemanager.webapp.address") +
"/ws/v1/cluster/apps/${job_id}?anonymous=true"liam <[email protected]>于2015年8月1日周六 下午4:01写道： > Hi,all > > It seems failed when build Json from the " > yarn.resourcemanager.webapp.address" response. > > I hope that somebody had meet this issue, and offer me some userful > message. > > Thanks. > > [--------------ERROR Message-------------] > > [pool-7-thread-1]:[2015-08-01 > > 15:37:48,952][INFO][org.apache.kylin.job.common.MapReduceExecutable.doWork(MapReduceExecutable.java:102)] > - mr_job_id:null > > [pool-7-thread-1]:[2015-08-01 > > 15:37:49,212][WARN][org.apache.commons.httpclient.HttpMethodBase.getResponseBody(HttpMethodBase.java:682)] > - Going to buffer response body of large or unknown size. Using > getResponseBodyAsStream instead is recommended. > > [pool-7-thread-1]:[2015-08-01 > > 15:37:49,231][DEBUG][org.apache.kylin.job.tools.HadoopStatusGetter.getHttpResponse(HadoopStatusGetter.java:92)] > - Job job_1435903628749_1320 get status check result. > > *[pool-7-thread-1]:[2015-08-01 > > 15:37:49,241][ERROR][org.apache.kylin.job.tools.HadoopStatusChecker.checkStatus(HadoopStatusChecker.java:91)] > - error check status* > > *org.codehaus.jackson.JsonParseException: Unexpected character ('<' (code > 60)): expected a valid value (number, String, array, object, 'true', > 'false' or 'null')* > > * at [Source: java.io.StringReader@5510ae29; line: 1, column: 2]* > > at org.codehaus.jackson.JsonParser._constructError(JsonParser.java:1292) > > at > > org.codehaus.jackson.impl.JsonParserMinimalBase._reportError(JsonParserMinimalBase.java:385) > > at > > org.codehaus.jackson.impl.JsonParserMinimalBase._reportUnexpectedChar(JsonParserMinimalBase.java:306) > > at > > org.codehaus.jackson.impl.ReaderBasedParser._handleUnexpectedValue(ReaderBasedParser.java:630) > > at > > org.codehaus.jackson.impl.ReaderBasedParser.nextToken(ReaderBasedParser.java:364) > > at > > org.codehaus.jackson.map.ObjectMapper._initForReading(ObjectMapper.java:2439) > > at > > org.codehaus.jackson.map.ObjectMapper._readMapAndClose(ObjectMapper.java:2396) > > at org.codehaus.jackson.map.ObjectMapper.readValue(ObjectMapper.java:1616) > > at org.codehaus.jackson.map.ObjectMapper.readTree(ObjectMapper.java:1291) > > at > > org.apache.kylin.job.tools.HadoopStatusGetter.get(HadoopStatusGetter.java:55) > > at > > org.apache.kylin.job.tools.HadoopStatusChecker.checkStatus(HadoopStatusChecker.java:56) > > at > > org.apache.kylin.job.common.MapReduceExecutable.doWork(MapReduceExecutable.java:136) > > at > > org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:106) > > at > > org.apache.kylin.job.execution.DefaultChainedExecutable.doWork(DefaultChainedExecutable.java:50) > > at > > org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:106) > > at > > org.apache.kylin.job.impl.threadpool.DefaultScheduler$JobRunner.run(DefaultScheduler.java:133) > > at > > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > > at > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) > > at java.lang.Thread.run(Thread.java:745) > -- Best Regard ZhouQianhao
