You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Gary Yao (JIRA)" <ji...@apache.org> on 2018/03/08 08:20:00 UTC
[jira] [Created] (FLINK-8894) CurrentJobIdsHandler fails to
serialize response
Gary Yao created FLINK-8894:
-------------------------------
Summary: 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
Reporter: Gary Yao
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)