[jira] [Created] (FLINK-11243) GroupBy udf() can not be select in TableAPI

[Shang Yuanchun (Jira)]

sunjincheng created FLINK-11243:
-----------------------------------

             Summary: GroupBy udf() can not be select in TableAPI
                 Key: FLINK-11243
                 URL: https://issues.apache.org/jira/browse/FLINK-11243
             Project: Flink
          Issue Type: Bug
          Components: Table API & SQL
    Affects Versions: 1.8.0
            Reporter: sunjincheng


The group key can not be select in the follows TableAPI:
{code:java}
val result = order
  .groupBy('o_time.substring(1, 16))
  .select('o_time.substring(1, 16), 'o_id.count){code}
Exception:
{code:java}
org.apache.flink.table.api.ValidationException: Cannot resolve field [o_time] given input [('o_time).substring(1, 16), TMP_0].

at org.apache.flink.table.plan.logical.LogicalNode.failValidation(LogicalNode.scala:156){code}
BTW, We can only use the following description to avoid the above problem.
{code:java}
val result = order
  .select('o_id, 'c_id, 'o_time.substring(1, 16) as 'key)
  .groupBy('key)
  .select('key, 'o_id.count)
{code}

But I think it is better to make `groupby udf()` can be select in TableAPI. What do you think?






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