[jira] [Created] (FLINK-4224) Exception after successful execution when submitting job through the web interface.

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-4224) Exception after successful execution when submitting job through the web interface.

Shang Yuanchun (Jira)
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)