You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/18 18:01:00 UTC
[jira] [Resolved] (FLINK-8894) CurrentJobIdsHandler fails to
serialize response
[ https://issues.apache.org/jira/browse/FLINK-8894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Till Rohrmann resolved FLINK-8894.
----------------------------------
Resolution: Fixed
Fixed via
1.6.0: 096a89ae6d0db9d763648a0acca2334f14efd3b3
1.5.0: 7739cb71d9a3d476c66cdd29f26744e5ef3eb1b3
> 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
> Assignee: 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)