It is good to hear that. You are welcome liam <[email protected]>于2015年8月1日周六 下午5:33写道:
> Hi,周千昊 > I solved the problem according to your tips. > Thanks. > > 2015-08-01 16:15 GMT+08:00 周千昊 <[email protected]>: > > > 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 > > > -- Best Regard ZhouQianhao
