flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4224) Exception after successful execution os job submitted through the web interface.
Date Tue, 02 Aug 2016 15:13:21 GMT

    [ https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404157#comment-15404157
] 

Aljoscha Krettek commented on FLINK-4224:
-----------------------------------------

[~kkl0u] is this still an issue on the new 1.1 RC?

> Exception after successful execution os job submitted 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
>            Assignee: Aljoscha Krettek
>
> 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.");
> 	}
>   
>         public static final class Tokenizer implements FlatMapFunction<String, Tuple2<String,
Integer>> {
> 		private static final long serialVersionUID = 1L;
> 		@Override
> 		public void flatMap(String value, Collector<Tuple2<String, Integer>> out)
> 				throws Exception {
> 			// normalize and split the line
> 			String[] tokens = value.toLowerCase().split("\\W+");
> 			// emit the pairs
> 			for (String token : tokens) {
> 				if (token.length() > 0) {
> 					out.collect(new Tuple2<>(token, 1));
> 				}
> 			}
> 		}
> 	}
> {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