Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-20787 Improve the Table API to make it usable
  3. FLINK-20788

It doesn't support to use cube/rollup/grouping sets in the Table API

    XMLWordPrintableJSON

    Details

    • Type: Sub-task
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: 1.14.0
    • Component/s: Table SQL / API
    • Labels:
      None

      Description

      Currently, it doesn't support to use cube/rollup/grouping sets in the Table API. For the following job:

      table.groupBy("cube(a, b)")
      

      It will throw the following exception:

      org.apache.flink.table.api.ValidationException: Undefined function: cube
      	at org.apache.flink.table.expressions.resolver.LookupCallResolver.lambda$visit$0(LookupCallResolver.java:49)
      	at java.util.Optional.orElseThrow(Optional.java:290)
      	at org.apache.flink.table.expressions.resolver.LookupCallResolver.visit(LookupCallResolver.java:49)
      	at org.apache.flink.table.expressions.resolver.LookupCallResolver.visit(LookupCallResolver.java:38)
      	at org.apache.flink.table.expressions.ApiExpressionVisitor.visit(ApiExpressionVisitor.java:37)
      	at org.apache.flink.table.expressions.LookupCallExpression.accept(LookupCallExpression.java:65)
      	at org.apache.flink.table.expressions.resolver.rules.LookupCallByNameRule.lambda$apply$0(LookupCallByNameRule.java:38)
      	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
      	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1374)
      	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.resolver.rules.LookupCallByNameRule.apply(LookupCallByNameRule.java:38)
      	at org.apache.flink.table.expressions.resolver.ExpressionResolver.lambda$null$1(ExpressionResolver.java:211)
      	at java.util.function.Function.lambda$andThen$1(Function.java:88)
      	at java.util.function.Function.lambda$andThen$1(Function.java:88)
      	at java.util.function.Function.lambda$andThen$1(Function.java:88)
      	at java.util.function.Function.lambda$andThen$1(Function.java:88)
      	at java.util.function.Function.lambda$andThen$1(Function.java:88)
      	at java.util.function.Function.lambda$andThen$1(Function.java:88)
      	at java.util.function.Function.lambda$andThen$1(Function.java:88)
      	at org.apache.flink.table.expressions.resolver.ExpressionResolver.resolve(ExpressionResolver.java:178)
      	at org.apache.flink.table.operations.utils.OperationTreeBuilder.aggregate(OperationTreeBuilder.java:236)
      	at org.apache.flink.table.api.internal.TableImpl$GroupedTableImpl.select(TableImpl.java:632)
      	at org.apache.flink.table.api.internal.TableImpl$GroupedTableImpl.select(TableImpl.java:615)
      

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              dian.fu Dian Fu
            • Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

              • Created:
                Updated: