[
https://issues.apache.org/jira/browse/FLINK-16315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther closed FLINK-16315.
--------------------------------
Resolution: Won't Fix
Since the old planner has been removed, I will close this issue now.
> throw JsonMappingException when using BatchTableEnvironment#explain to get
> the plan of sql with constant string
> -----------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-16315
> URL: https://issues.apache.org/jira/browse/FLINK-16315
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Legacy Planner
> Reporter: godfrey he
> Priority: Minor
> Labels: auto-deprioritized-major
>
> {code:java}
> ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
> BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);
> tEnv.registerTableSource("MyTable", CommonTestData.getCsvTableSource());
> Table table = tEnv.sqlQuery("select * from MyTable where first = '274' ");
> System.out.println(tEnv.explain(table));
> {code}
> when executing the above code, the following exception will occur.
> {panel:title=exception}
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonMappingException:
> Unexpected character ('U' (code 85)): was expecting comma to separate Object
> entries
> at [Source: (String)"{
> "nodes": [
> {
> "id": 2,
> "type": "source",
> "pact": "Data Source",
> "contents": "CsvTableSource(read fields: first, id, score,
> last)",
> "parallelism": "8",
> "global_properties": [
> { "name": "Partitioning", "value": "RANDOM_PARTITIONED"
> },
> { "name": "Partitioning Order", "value": "(none)" },
> { "name": "Uniqueness", "value": "not unique" }
> ],
> "local_properties": [
> { "name": "Order", "value": "(none)" },
> { "name": "Grouping", "value": "not grouped" },
> { "name": "Uniq"[truncated 3501 chars]; line: 41,
> column: 15] (through reference chain:
> org.apache.flink.table.explain.PlanTree["nodes"]->java.util.ArrayList[1])
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonMappingException.wrapWithPath(JsonMappingException.java:394)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonMappingException.wrapWithPath(JsonMappingException.java:365)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.CollectionDeserializer.deserialize(CollectionDeserializer.java:302)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.CollectionDeserializer.deserialize(CollectionDeserializer.java:245)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.CollectionDeserializer.deserialize(CollectionDeserializer.java:27)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.impl.FieldProperty.deserializeAndSet(FieldProperty.java:138)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.vanillaDeserialize(BeanDeserializer.java:288)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize(BeanDeserializer.java:151)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4202)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3205)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3173)
> at
> org.apache.flink.table.explain.PlanJsonParser.getSqlExecutionPlan(PlanJsonParser.java:42)
> at
> org.apache.flink.table.api.internal.BatchTableEnvImpl.explain(BatchTableEnvImpl.scala:208)
> at
> org.apache.flink.table.api.internal.BatchTableEnvImpl.explain(BatchTableEnvImpl.scala:223)
> {panel}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
