Kostas Kloudas created FLINK-4224:
-------------------------------------
Summary: Exception after successful execution when submitting job
through the web interface.
Key: FLINK-4224
URL: https://issues.apache.org/jira/browse/FLINK-4224
Project: Flink
Issue Type: Bug
Affects Versions: 1.1.0
Reporter: Kostas Kloudas
When submitting the job below through the web interface to a local flink
cluster:
{code}
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env =
SreamExecutionEnvironment.getExecutionEnvironment();
TextInputFormat inputFormat =
new TextInputFormat(new
Path("file:///YOUR_TEXT_FILE"));
DataStream<Tuple2<String, Integer>> input = env.
readFile(inputFormat,inputFormat.getFilePath().toString()).
flatMap(new Tokenizer()).
keyBy(0).
sum(1);
input.print();
env.execute("WebClient Testing Example.");
}
{/code}
The job succeeds, but at the logs there is a NPE:
{code}
2016-07-16 16:56:18,197 WARN
org.apache.flink.runtime.webmonitor.RuntimeMonitorHandler -
Error while handling request java.lang.RuntimeException:
Couldn't deserialize ExecutionConfig.
...
Caused by: java.lang.NullPointerException at
org.apache.flink.util.SerializedValue.deserializeValue(SerializedValue.java:55)at
org.apache.flink.runtime.webmonitor.handlers.JobConfigHandler.handleRequest(JobConfigHandler.java:50)
{/code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
