Wei Zhong created FLINK-17570:
---------------------------------
Summary: BatchTableEnvironment#fromValues(Object... values) causes
StackOverflowError
Key: FLINK-17570
URL: https://issues.apache.org/jira/browse/FLINK-17570
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Reporter: Wei Zhong
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)
