[
https://issues.apache.org/jira/browse/FLINK-17570?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz closed FLINK-17570.
------------------------------------
Resolution: Fixed
Fixed via 571c0892fa30a34751b575c10b78472eed8849e2
> BatchTableEnvironment#fromValues(Object... values) throws StackOverflowError
> -----------------------------------------------------------------------------
>
> Key: FLINK-17570
> URL: https://issues.apache.org/jira/browse/FLINK-17570
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / API
> Affects Versions: 1.11.0
> Reporter: Wei Zhong
> Assignee: Dawid Wysakowicz
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.11.0
>
>
> The Error can be reproduced by following code:
> {code:java}
> ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
> BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);
> tEnv.fromValues(1L, 2L, 3L);
> {code}
> The Error is as following:
> {code:java}
> Exception in thread "main" java.lang.StackOverflowErrorException in thread
> "main" java.lang.StackOverflowError at
> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193) at
> java.util.stream.IntPipeline$4$1.accept(IntPipeline.java:250) at
> java.util.stream.Streams$RangeIntSpliterator.forEachRemaining(Streams.java:110)
> at java.util.Spliterator$OfInt.forEachRemaining(Spliterator.java:693) at
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481) at
> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)
> at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
> at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) at
> java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499) at
> org.apache.flink.table.expressions.ApiExpressionUtils.convertArray(ApiExpressionUtils.java:142)
> at
> org.apache.flink.table.expressions.ApiExpressionUtils.objectToExpression(ApiExpressionUtils.java:100)
> at
> org.apache.flink.table.api.internal.TableEnvImpl$$anonfun$2.apply(TableEnvImpl.scala:1030)
> at
> org.apache.flink.table.api.internal.TableEnvImpl$$anonfun$2.apply(TableEnvImpl.scala:1030)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at scala.collection.Iterator$class.foreach(Iterator.scala:891) at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1334) at
> scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54) at
> scala.collection.TraversableLike$class.map(TraversableLike.scala:234) at
> scala.collection.AbstractTraversable.map(Traversable.scala:104) at
> org.apache.flink.table.api.internal.TableEnvImpl.fromValues(TableEnvImpl.scala:1030)
> at
> org.apache.flink.table.api.TableEnvironment.fromValues(TableEnvironment.java:163)
> at
> org.apache.flink.table.api.internal.TableEnvImpl.fromValues(TableEnvImpl.scala:1032)
> at
> org.apache.flink.table.api.TableEnvironment.fromValues(TableEnvironment.java:163)
> at
> org.apache.flink.table.api.internal.TableEnvImpl.fromValues(TableEnvImpl.scala:1032)
> at
> org.apache.flink.table.api.TableEnvironment.fromValues(TableEnvironment.java:163)
> at
> org.apache.flink.table.api.internal.TableEnvImpl.fromValues(TableEnvImpl.scala:1032)
> at
> org.apache.flink.table.api.TableEnvironment.fromValues(TableEnvironment.java:163)
> at
> org.apache.flink.table.api.internal.TableEnvImpl.fromValues(TableEnvImpl.scala:1032)
> at
> org.apache.flink.table.api.TableEnvironment.fromValues(TableEnvironment.java:163)
> ...{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
