Jiang Xin created FLINK-32424:
---------------------------------
Summary: Flink ML CI fails due to NPE
Key: FLINK-32424
URL: https://issues.apache.org/jira/browse/FLINK-32424
Project: Flink
Issue Type: Bug
Components: Library / Machine Learning
Reporter: Jiang Xin
Fix For: ml-2.4.0
build link:
https://github.com/apache/flink-ml/actions/runs/5368445516/jobs/9739341715?pr=244
The full stack is as below.
{code:java}
E py4j.protocol.Py4JJavaError: An error occurred while
calling o64144.fit.
99E : java.lang.NullPointerException: metadataHandlerProvider
100E at java.util.Objects.requireNonNull(Objects.java:228)
101E at
org.apache.calcite.rel.metadata.RelMetadataQueryBase.getMetadataHandlerProvider(RelMetadataQueryBase.java:122)
102E at
org.apache.calcite.rel.metadata.RelMetadataQueryBase.revise(RelMetadataQueryBase.java:118)
103E at
org.apache.calcite.rel.metadata.RelMetadataQuery.getPulledUpPredicates(RelMetadataQuery.java:844)
104E at
org.apache.calcite.rel.rules.ReduceExpressionsRule$ProjectReduceExpressionsRule.onMatch(ReduceExpressionsRule.java:307)
105E at
org.apache.calcite.plan.AbstractRelOptPlanner.fireRule(AbstractRelOptPlanner.java:337)
106E at
org.apache.calcite.plan.hep.HepPlanner.applyRule(HepPlanner.java:565)
107E at
org.apache.calcite.plan.hep.HepPlanner.applyRules(HepPlanner.java:428)
108E at
org.apache.calcite.plan.hep.HepPlanner.executeInstruction(HepPlanner.java:251)
109E at
org.apache.calcite.plan.hep.HepInstruction$RuleInstance.execute(HepInstruction.java:130)
110E at
org.apache.calcite.plan.hep.HepPlanner.executeProgram(HepPlanner.java:208)
111E at
org.apache.calcite.plan.hep.HepPlanner.findBestExp(HepPlanner.java:195)
112E at
org.apache.flink.table.planner.plan.optimize.program.FlinkHepProgram.optimize(FlinkHepProgram.scala:64)
113E at
org.apache.flink.table.planner.plan.optimize.program.FlinkHepRuleSetProgram.optimize(FlinkHepRuleSetProgram.scala:78)
114E at
org.apache.flink.table.planner.plan.optimize.program.FlinkChainedProgram.$anonfun$optimize$1(FlinkChainedProgram.scala:59)
115E at
scala.collection.TraversableOnce.$anonfun$foldLeft$1(TraversableOnce.scala:156)
116E at
scala.collection.TraversableOnce.$anonfun$foldLeft$1$adapted(TraversableOnce.scala:156)
117E at scala.collection.Iterator.foreach(Iterator.scala:937)
118E at
scala.collection.Iterator.foreach$(Iterator.scala:937)
119E at
scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
120E at
scala.collection.IterableLike.foreach(IterableLike.scala:70)
121E at
scala.collection.IterableLike.foreach$(IterableLike.scala:69)
122E at
scala.collection.AbstractIterable.foreach(Iterable.scala:54)
123E at
scala.collection.TraversableOnce.foldLeft(TraversableOnce.scala:156)
124E at
scala.collection.TraversableOnce.foldLeft$(TraversableOnce.scala:154)
125E at
scala.collection.AbstractTraversable.foldLeft(Traversable.scala:104)
126E at
org.apache.flink.table.planner.plan.optimize.program.FlinkChainedProgram.optimize(FlinkChainedProgram.scala:55)
127E at
org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.optimizeTree(StreamCommonSubGraphBasedOptimizer.scala:176)
128E at
org.apache.flink.table.planner.plan.optimize.StreamCommonSubGraphBasedOptimizer.doOptimize(StreamCommonSubGraphBasedOptimizer.scala:83)
129E at
org.apache.flink.table.planner.plan.optimize.CommonSubGraphBasedOptimizer.optimize(CommonSubGraphBasedOptimizer.scala:87)
130E at
org.apache.flink.table.planner.delegation.PlannerBase.optimize(PlannerBase.scala:329)
131E at
org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:195)
132E at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.toStreamInternal(AbstractStreamTableEnvironmentImpl.java:224)
133E at
org.apache.flink.table.api.bridge.internal.AbstractStreamTableEnvironmentImpl.toStreamInternal(AbstractStreamTableEnvironmentImpl.java:219)
134E at
org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.toDataStream(StreamTableEnvironmentImpl.java:253)
135E at
org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.toDataStream(StreamTableEnvironmentImpl.java:226)
136E at
org.apache.flink.ml.feature.robustscaler.RobustScaler.fit(RobustScaler.java:77)
137E at
org.apache.flink.ml.feature.robustscaler.RobustScaler.fit(RobustScaler.java:62)
138E at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method)
139E at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
140E at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
141E at java.lang.reflect.Method.invoke(Method.java:498)
142E at
org.apache.flink.api.python.shaded.py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
143E at
org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:374)
144E at
org.apache.flink.api.python.shaded.py4j.Gateway.invoke(Gateway.java:282)
145E at
org.apache.flink.api.python.shaded.py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
146E at
org.apache.flink.api.python.shaded.py4j.commands.CallCommand.execute(CallCommand.java:79)
147E at
org.apache.flink.api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238)
148E at java.lang.Thread.run(Thread.java:750) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
