[
https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4224:
----------------------------------
Description:
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}
was:
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}
> 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
>
> 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)
