Hi Pangongsen, Do you upgrade the Flink-related dependencies you use at the same time? In other words, is the dependency consistent with the flink version?
Thanks, vino. ? ?? <pangong...@hotmail.com> 于2018年9月4日周二 下午10:07写道： > 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 > >
