You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Lian Jiang <ji...@gmail.com> on 2020/07/17 00:42:44 UTC
Flink 1.11 throws Unrecognized field "error_code"
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)
Re: Flink 1.11 throws Unrecognized field "error_code"
Posted by Lian Jiang <ji...@gmail.com>.
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 <ch...@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>
Re: Flink 1.11 throws Unrecognized field "error_code"
Posted by Chesnay Schepler <ch...@apache.org>.
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)