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)