[jira] [Commented] (FLINK-6618) Fix GroupWindowStringExpressionTest testcase bug

["Alexis Sarda-Espinosa (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-6618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16618780#comment-16618780 ] 

Alexis Sarda-Espinosa commented on FLINK-6618:
----------------------------------------------

I'm not sure if I should post on older issues but, was the second bug actually fixed, [~fhueske]? I am getting the same type of exception with Flink 1.5.3 (Cannot resolve [w] given input ...).

> Fix GroupWindowStringExpressionTest testcase bug
> ------------------------------------------------
>
>                 Key: FLINK-6618
>                 URL: https://issues.apache.org/jira/browse/FLINK-6618
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Table API & SQL
>    Affects Versions: 1.3.0
>            Reporter: sunjincheng
>            Assignee: sunjincheng
>            Priority: Major
>             Fix For: 1.3.0, 1.4.0
>
>
> I find 2 bugs as follows:
> 1. {{GroupWindowStringExpressionTest}} testcase bug:
> {{Assert.assertEquals("Logical Plans do not match", resJava.logicalPlan, resJava.logicalPlan)}} -> {{verifyTableEquals(resJava, resScala)}}
> 2. Window properties can not select in JAVA API:
> Java Code:
> {code}
>  // String / Java API
>     val resJava = t
>       .window(JSlide.over("4.hours").every("2.hours").on("rowtime") as 'w)
>       .groupBy("w, string")
>       .select(
>         "string, " +
>         "myCountFun(string), " +
>         "int.sum, " +
>         "weightAvgFun(long, int), " +
>         "weightAvgFun(int, int) * 2, " +
>         "start(w)," +
>         "end(w)")
> {code}
> Exception Info:
> {code}
> org.apache.flink.table.api.ValidationException: Cannot resolve [w] given input [int, long, string, rowtime].
> 	at org.apache.flink.table.plan.logical.LogicalNode.failValidation(LogicalNode.scala:143)
> 	at org.apache.flink.table.plan.logical.LogicalNode$$anonfun$validate$1.applyOrElse(LogicalNode.scala:86)
> 	at org.apache.flink.table.plan.logical.LogicalNode$$anonfun$validate$1.applyOrElse(LogicalNode.scala:83)
> 	at org.apache.flink.table.plan.TreeNode.postOrderTransform(TreeNode.scala:72)
> 	at org.apache.flink.table.plan.logical.LogicalNode.org$apache$flink$table$plan$logical$LogicalNode$$expressionPostOrderTransform$1(LogicalNode.scala:119)
> 	at org.apache.flink.table.plan.logical.LogicalNode$$anonfun$7$$anonfun$apply$1.apply(LogicalNode.scala:132)
> 	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.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
>  {code}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)