[
https://issues.apache.org/jira/browse/FLINK-6479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-6479.
--------------------------------
Resolution: Fixed
Fix Version/s: 1.4.0
1.3.0
Fixed for 1.3.0 with 4556b49c80108e83d67a56ac5039f631dd681a96
Fixed for 1.4.0 with f26a911627204519a78ccc57b1f12b387d85e43b
> Fix IndexOutOfBoundsException bug
> ---------------------------------
>
> Key: FLINK-6479
> URL: https://issues.apache.org/jira/browse/FLINK-6479
> Project: Flink
> Issue Type: Bug
> Components: Table API & SQL
> Affects Versions: 1.3.0
> Reporter: sunjincheng
> Assignee: sunjincheng
> Fix For: 1.3.0, 1.4.0
>
>
> {code}
> val windowedTable = table
> .window(Slide over 2.rows every 1.rows on 'proctime as 'w)
> .groupBy('w, 'string)
> .select(weightAvgFun('long, 'int))
> {code}
> will got exception:
> {code}
> java.lang.IndexOutOfBoundsException: index (2) must be less than size (2)
> at
> com.google.common.base.Preconditions.checkElementIndex(Preconditions.java:310)
> at
> com.google.common.base.Preconditions.checkElementIndex(Preconditions.java:292)
> at
> com.google.common.collect.RegularImmutableList.get(RegularImmutableList.java:65)
> at org.apache.calcite.util.Pair$6.get(Pair.java:347)
> at
> scala.collection.convert.Wrappers$JListWrapper.apply(Wrappers.scala:88)
> at
> org.apache.flink.table.plan.nodes.CommonAggregate$$anonfun$groupingToString$1.apply(CommonAggregate.scala:34)
> at
> org.apache.flink.table.plan.nodes.CommonAggregate$$anonfun$groupingToString$1.apply(CommonAggregate.scala:34)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> at
> scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:244)
> at
> scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
> at scala.collection.mutable.ArrayOps$ofInt.foreach(ArrayOps.scala:156)
> at scala.collection.TraversableLike$class.map(TraversableLike.scala:244)
> at scala.collection.mutable.ArrayOps$ofInt.map(ArrayOps.scala:156)
> at
> org.apache.flink.table.plan.nodes.CommonAggregate$class.groupingToString(CommonAggregate.scala:34)
> at
> org.apache.flink.table.plan.nodes.datastream.DataStreamGroupWindowAggregate.groupingToString(DataStreamGroupWindowAggregate.scala:44)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
