Thanks Chesnay. Flink UI port 8081 conflicts with Confluent schema registry, causing cluster to fail to start. After changing the port, the cluster can start and the job can be submitted. Thanks.
On Fri, Jul 17, 2020 at 12:40 AM Chesnay Schepler <ches...@apache.org> wrote: > Please double-check that the client and server are using the same Flink > version. > > On 17/07/2020 02:42, Lian Jiang wrote: > > Hi, > > I am using java 1.8 and Flink 1.11 by following > https://ci.apache.org/projects/flink/flink-docs-release-1.11/try-flink/local_installation.html > on my MAC Mojave 10.14.6. But " > > ./bin/flink run examples/streaming/WordCount.jar > > " throw below error. These are the java versions that I tried: > > 1.8.0_222, x86_64: "AdoptOpenJDK 8" > /Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home > 1.8.0_221, x86_64: "Java SE 8" > /Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home > 1.8.0_181, x86_64: "Java SE 8" > /Library/Java/JavaVirtualMachines/jdk1.8.0_181.jdk/Contents/Home > > They all behave the same. Any idea is highly appreciated! > > > Error: > > Caused by: > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: > Unrecognized field "error_code" (class > org.apache.flink.runtime.rest.messages.job.JobSubmitResponseBody), not > marked as ignorable (one known property: "jobUrl"]) > at [Source: UNKNOWN; line: -1, column: -1] (through reference chain: > org.apache.flink.runtime.rest.messages.job.JobSubmitResponseBody["error_code"]) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException.from(UnrecognizedPropertyException.java:61) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.handleUnknownProperty(DeserializationContext.java:840) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StdDeserializer.handleUnknownProperty(StdDeserializer.java:1192) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializerBase.handleUnknownProperty(BeanDeserializerBase.java:1592) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializerBase.handleUnknownProperties(BeanDeserializerBase.java:1542) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer._deserializeUsingPropertyBased(BeanDeserializer.java:504) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializerBase.deserializeFromObjectUsingNonDefault(BeanDeserializerBase.java:1287) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject(BeanDeserializer.java:326) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize(BeanDeserializer.java:159) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._readValue(ObjectMapper.java:4173) > at > org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:2536) > at > org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:382) > > > -- Create your own email signature <https://www.wisestamp.com/signature-in-email/?utm_source=promotion&utm_medium=signature&utm_campaign=create_your_own&srcid=5234462839406592>
