[
https://issues.apache.org/jira/browse/FLINK-40062?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-40062:
------------------------------------
Description:
{{Welford}} was introduced in FLINK-38740
restoring from plan just fails as
{noformat}
lizerBase.java:1497)
at
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject(BeanDeserializer.java:348)
at
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize(BeanDeserializer.java:185)
at
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.readValue(DeserializationContext.java:992)
at
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.readValue(DeserializationContext.java:979)
at
org.apache.flink.table.planner.plan.nodes.exec.serde.ExecNodeGraphJsonDeserializer.deserialize(ExecNodeGraphJsonDeserializer.java:50)
at
org.apache.flink.table.planner.plan.nodes.exec.serde.ExecNodeGraphJsonDeserializer.deserialize(ExecNodeGraphJsonDeserializer.java:37)
at
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.DefaultDeserializationContext.readRootValue(DefaultDeserializationContext.java:342)
at
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader._bindAndClose(ObjectReader.java:2125)
at
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader.readValue(ObjectReader.java:1566)
at
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader.readValue(ObjectReader.java:1586)
at
org.apache.flink.table.planner.delegation.PlannerBase.loadPlan(PlannerBase.scala:197)
at
org.apache.flink.table.api.internal.TableEnvironmentImpl.loadPlan(TableEnvironmentImpl.java:947)
... 60 more
Caused by: org.apache.flink.table.api.TableException: Could not resolve
internal system function '$$WELFORD_M2$1$1'. This is a bug, please file an
issue.
at
org.apache.flink.table.planner.plan.nodes.exec.serde.RexNodeJsonDeserializer.deserializeInternalFunction(RexNodeJsonDeserializer.java:438)
at
org.apache.flink.table.planner.plan.nodes.exec.serde.RexNodeJsonDeserializer.deserializeSqlOperator(RexNodeJsonDeserializer.java:383)
at
org.apache.flink.table.planner.plan.nodes.exec.serde.AggregateCallJsonDeserializer.deserialize(AggregateCallJsonDeserializer.java:69)
at
org.apache.flink.table.planner.plan.nodes.exec.serde.AggregateCallJsonDeserializer.deserialize(AggregateCallJsonDeserializer.java:51)
at
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.ObjectArrayDeserializer.deserialize(ObjectArrayDeserializer.java:218)
... 89 more
{noformat}
was:{{Welford}} was introduced in FLINK-38740
> Compiled plans with WELFORD function are not able to be loaded/deserialized
> ---------------------------------------------------------------------------
>
> Key: FLINK-40062
> URL: https://issues.apache.org/jira/browse/FLINK-40062
> Project: Flink
> Issue Type: Technical Debt
> Components: Table SQL / Planner
> Reporter: Sergey Nuyanzin
> Assignee: Sergey Nuyanzin
> Priority: Major
> Labels: pull-request-available
>
> {{Welford}} was introduced in FLINK-38740
> restoring from plan just fails as
> {noformat}
> lizerBase.java:1497)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserializeFromObject(BeanDeserializer.java:348)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.BeanDeserializer.deserialize(BeanDeserializer.java:185)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.readValue(DeserializationContext.java:992)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext.readValue(DeserializationContext.java:979)
> at
> org.apache.flink.table.planner.plan.nodes.exec.serde.ExecNodeGraphJsonDeserializer.deserialize(ExecNodeGraphJsonDeserializer.java:50)
> at
> org.apache.flink.table.planner.plan.nodes.exec.serde.ExecNodeGraphJsonDeserializer.deserialize(ExecNodeGraphJsonDeserializer.java:37)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.DefaultDeserializationContext.readRootValue(DefaultDeserializationContext.java:342)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader._bindAndClose(ObjectReader.java:2125)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader.readValue(ObjectReader.java:1566)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectReader.readValue(ObjectReader.java:1586)
> at
> org.apache.flink.table.planner.delegation.PlannerBase.loadPlan(PlannerBase.scala:197)
> at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.loadPlan(TableEnvironmentImpl.java:947)
> ... 60 more
> Caused by: org.apache.flink.table.api.TableException: Could not resolve
> internal system function '$$WELFORD_M2$1$1'. This is a bug, please file an
> issue.
> at
> org.apache.flink.table.planner.plan.nodes.exec.serde.RexNodeJsonDeserializer.deserializeInternalFunction(RexNodeJsonDeserializer.java:438)
> at
> org.apache.flink.table.planner.plan.nodes.exec.serde.RexNodeJsonDeserializer.deserializeSqlOperator(RexNodeJsonDeserializer.java:383)
> at
> org.apache.flink.table.planner.plan.nodes.exec.serde.AggregateCallJsonDeserializer.deserialize(AggregateCallJsonDeserializer.java:69)
> at
> org.apache.flink.table.planner.plan.nodes.exec.serde.AggregateCallJsonDeserializer.deserialize(AggregateCallJsonDeserializer.java:51)
> at
> org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.ObjectArrayDeserializer.deserialize(ObjectArrayDeserializer.java:218)
> ... 89 more
> {noformat}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
