I can get the value with /joboverview under the 1.3.2. Thanks ~







At 2018-03-08 16:29:34, "Gary Yao" <g...@data-artisans.com> wrote:
>Hi Minglei,
>
>What Flink version are you using? The path was only recently changed to
>/jobs/overview [1], and you linked to the documentation of the snapshot
>version.
>While I tested the feature, I discovered another bug in 1.5, though [2].
>
>Best,
>Gary
>
>[1] https://issues.apache.org/jira/browse/FLINK-7806
>[2] https://issues.apache.org/jira/browse/FLINK-8894
>
>
>On Wed, Mar 7, 2018 at 4:18 AM, mingleizhang <zml13856086...@163.com> wrote:
>
>>
>>
>> I expect it response me like the following as the doc say. But does not.
>>
>>
>>
>> Sample Result:
>>
>> {
>>   "jobs":[
>>     {
>>       "jid": "7684be6004e4e955c2a558a9bc463f65",
>>       "name": "Flink Java Job at Wed Sep 16 18:08:21 CEST 2015",
>>       "state": "FINISHED",
>>       "start-time": 1442419702857,
>>       "end-time": 1442419975312,
>>       "duration":272455,
>>       "last-modification": 1442419975312,
>>       "tasks": {
>>          "total": 6,
>>          "pending": 0,
>>          "running": 0,
>>          "finished": 6,
>>          "canceling": 0,
>>          "canceled": 0,
>>          "failed": 0
>>       }
>>     },
>>     {
>>       "jid": "49306f94d0920216b636e8dd503a6409",
>>       "name": "Flink Java Job at Wed Sep 16 18:16:39 CEST 2015",
>>       ...
>>     }]
>> }
>>
>>
>>
>>
>>
>>
>>
>> At 2018-03-07 11:14:11, "mingleizhang" <zml13856086...@163.com> wrote:
>> >I am not sure about whether it is a incorrect rest url, but i think it is.
>> >
>> >
>> >https://ci.apache.org/projects/flink/flink-docs-
>> master/monitoring/rest_api.html
>> >Overview of Jobs
>> >/jobs/overview
>> >
>> >And I access the url with :
>> >
>> >http://10.201.202.217:9081//jobs/overview
>> >
>> >It gives me :
>> >
>> >java.lang.RuntimeException: Invalid JobID string 'overview': contains
>> illegal character for hexBinary: overview
>> >
>> >       at org.apache.flink.runtime.webmonitor.handlers.
>> AbstractExecutionGraphRequestHandler.handleJsonRequest(
>> AbstractExecutionGraphRequestHandler.java:53)
>> >       at org.apache.flink.runtime.webmonitor.handlers.
>> AbstractJsonRequestHandler.handleRequest(AbstractJsonRequestHandler.
>> java:41)
>> >       at org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler.
>> respondAsLeader(RuntimeMonitorHandler.java:109)
>> >       at org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase.
>> channelRead0(RuntimeMonitorHandlerBase.java:97)
>> >       at org.apache.flink.runtime.webmonitor.RuntimeMonitorHandlerBase.
>> channelRead0(RuntimeMonitorHandlerBase.java:44)
>> >       at io.netty.channel.SimpleChannelInboundHandler.channelRead(
>> SimpleChannelInboundHandler.java:105)
>> >       at io.netty.channel.AbstractChannelHandlerContext.
>> invokeChannelRead(AbstractChannelHandlerContext.java:339)
>> >       at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
>> AbstractChannelHandlerContext.java:324)
>> >       at io.netty.handler.codec.http.router.Handler.routed(Handler.
>> java:62)
>> >       at io.netty.handler.codec.http.router.DualAbstractHandler.
>> channelRead0(DualAbstractHandler.java:57)
>> >       at io.netty.handler.codec.http.router.DualAbstractHandler.
>> channelRead0(DualAbstractHandler.java:20)
>> >       at io.netty.channel.SimpleChannelInboundHandler.channelRead(
>> SimpleChannelInboundHandler.java:105)
>> >       at io.netty.channel.AbstractChannelHandlerContext.
>> invokeChannelRead(AbstractChannelHandlerContext.java:339)
>> >       at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
>> AbstractChannelHandlerContext.java:324)
>> >       at org.apache.flink.runtime.webmonitor.HttpRequestHandler.
>> channelRead0(HttpRequestHandler.java:105)
>> >       at org.apache.flink.runtime.webmonitor.HttpRequestHandler.
>> channelRead0(HttpRequestHandler.java:65)
>> >       at io.netty.channel.SimpleChannelInboundHandler.channelRead(
>> SimpleChannelInboundHandler.java:105)
>> >       at io.netty.channel.AbstractChannelHandlerContext.
>> invokeChannelRead(AbstractChannelHandlerContext.java:339)
>> >       at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
>> AbstractChannelHandlerContext.java:324)
>> >       at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(
>> ChannelInboundHandlerAdapter.java:86)
>> >       at io.netty.channel.AbstractChannelHandlerContext.
>> invokeChannelRead(AbstractChannelHandlerContext.java:339)
>> >       at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(
>> AbstractChannelHandlerContext.java:324)
>> >       at io.netty.handler.codec.ByteToMessageDecoder.channelRead(
>> ByteToMessageDecoder.java:242)
>> >
>> >
>> >Other than that, all works well.
>> >http://10.201.202.217:9081///config works fine.
>> >http://10.201.202.217:9081////overview works fine.
>> >
>> >
>> >thanks
>> >Minglei.
>> >
>> >
>> >
>> >
>> >
>>

Reply via email to