flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kostas Kloudas (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-4224) Exception after successful execution when submitting job through the web interface.
Date Sat, 16 Jul 2016 15:15:20 GMT
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)

Mime
View raw message