Mailing-List: contact issues-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
Date: Thu, 18 May 2017 09:43:04 +0000 (UTC)
From: "ASF GitHub Bot (JIRA)" <jira@apache.org>
To: issues@flink.apache.org
Message-ID: <JIRA.13072997.1495078386000.239437.1495100584301@Atlassian.JIRA>
In-Reply-To: <JIRA.13072997.1495078386000@Atlassian.JIRA>
References: <JIRA.13072997.1495078386000@Atlassian.JIRA> <JIRA.13072997.1495078386239@jira-lw-us.apache.org>
Subject: [jira] [Commented] (FLINK-6618) Fix GroupWindowStringExpressionTest
 testcase bug
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Thu, 18 May 2017 09:43:15 -0000


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

ASF GitHub Bot commented on FLINK-6618:
---------------------------------------

Github user fhueske commented on the issue:

    https://github.com/apache/flink/pull/3936
  
    Thanks for the update. +1 to merge


> 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
>
> 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
(v6.3.15#6346)