[jira] [Commented] (FLINK-8894) CurrentJobIdsHandler fails to serialize response

["mingleizhang (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16392520#comment-16392520 ] 

mingleizhang commented on FLINK-8894:
-------------------------------------

Hi, [~gjy] I want to reproduce this issue on my machine. But I do not know how to do {{Add mode: old to flink-conf.yaml}}. It seems I can not find a key that can set the cluster model for Flip6 or old in this yaml file. Could you tell you how you set that ? Thank you.

> CurrentJobIdsHandler fails to serialize response
> ------------------------------------------------
>
>                 Key: FLINK-8894
>                 URL: https://issues.apache.org/jira/browse/FLINK-8894
>             Project: Flink
>          Issue Type: Bug
>          Components: REST
>    Affects Versions: 1.5.0, 1.6.0
>            Reporter: Gary Yao
>            Priority: Blocker
>             Fix For: 1.5.0
>
>
> *Description*
> The non-flip6 {{CurrentJobIdsHandler}} fails to serialize instances of {{JobIdWithStatus}}.
> *Steps to reproduce*
> # Add {{mode: old}} to {{flink-conf.yaml}}
> # {{bin/start-cluster.sh}}
> # {{nc -l 9001}}
> # {{bin/flink run  examples/streaming/SocketWindowWordCount.jar --port 9001}}
> # {{curl localhost:8081/jobs}}
> *Stacktrace*
> {noformat}
> java.util.concurrent.CompletionException: org.apache.flink.util.FlinkException: Failed to fetch list of all running jobs.
> 	at org.apache.flink.runtime.rest.handler.legacy.CurrentJobIdsHandler.lambda$handleJsonRequest$0(CurrentJobIdsHandler.java:93)
> 	at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)
> 	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> 	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
> 	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
> 	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)
> Caused by: org.apache.flink.util.FlinkException: Failed to fetch list of all running jobs.
> 	... 9 more
> Caused by: java.lang.IllegalStateException: No ObjectCodec defined for the generator, can only serialize simple wrapper types (type passed org.apache.flink.runtime.messages.webmonitor.JobIdsWithStatusOverview$JobIdWithStatus)
> 	at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator._writeSimpleObject(JsonGenerator.java:1798)
> 	at org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.base.GeneratorBase.writeObject(GeneratorBase.java:369)
> 	at org.apache.
> {noformat}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)