[
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)
