Hi all,
     I use below way to submit jar to Flink :

StreamExecutionEnvironment env = 
StreamExecutionEnvironment.createRemoteEnvironment(config.clusterIp,
                                                                                
    config.clusterPort,
                                                                                
    config.clusterFlinkJar);


    I used Flink 1.3.2 before, and it works fine. But I upgrade it to 1.6.0, 
and I got the error below:

2018-09-04 21:38:32.039 [ERROR] [flink-rest-client-netty-19-1] 
org.apache.flink.runtime.rest.RestClient - Unexpected plain-text response:

2018-09-04 21:38:32.137 [ERROR] [flink-rest-client-netty-18-1] 
org.apache.flink.runtime.rest.RestClient - Response was not valid JSON.

org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonMappingException:
 No content to map due to end-of-input


    Could you give me some advice to fix it?

yours,
Gongsen

Reply via email to