[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2024-07-10 Thread Weijie Guo (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Weijie Guo updated FLINK-20788:
---
Fix Version/s: 2.0.0
   (was: 1.20.0)

> It doesn't support to use cube/rollup/grouping sets in the Table API
> 
>
> Key: FLINK-20788
> URL: https://issues.apache.org/jira/browse/FLINK-20788
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table SQL / API
>Reporter: Dian Fu
>Priority: Major
> Fix For: 2.0.0
>
>
> Currently, it doesn't support to use cube/rollup/grouping sets in the Table 
> API. For the following job:
> {code}
> table.groupBy("cube(a, b)")
> {code}
> It will throw the following exception:
> {code}
> 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)
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2024-03-11 Thread lincoln lee (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

lincoln lee updated FLINK-20788:

Fix Version/s: (was: 1.19.0)

> It doesn't support to use cube/rollup/grouping sets in the Table API
> 
>
> Key: FLINK-20788
> URL: https://issues.apache.org/jira/browse/FLINK-20788
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table SQL / API
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.20.0
>
>
> Currently, it doesn't support to use cube/rollup/grouping sets in the Table 
> API. For the following job:
> {code}
> table.groupBy("cube(a, b)")
> {code}
> It will throw the following exception:
> {code}
> 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)
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2024-03-11 Thread lincoln lee (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

lincoln lee updated FLINK-20788:

Fix Version/s: 1.20.0

> It doesn't support to use cube/rollup/grouping sets in the Table API
> 
>
> Key: FLINK-20788
> URL: https://issues.apache.org/jira/browse/FLINK-20788
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table SQL / API
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.19.0, 1.20.0
>
>
> Currently, it doesn't support to use cube/rollup/grouping sets in the Table 
> API. For the following job:
> {code}
> table.groupBy("cube(a, b)")
> {code}
> It will throw the following exception:
> {code}
> 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)
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2023-10-13 Thread Jing Ge (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jing Ge updated FLINK-20788:

Fix Version/s: 1.19.0
   (was: 1.18.0)

> It doesn't support to use cube/rollup/grouping sets in the Table API
> 
>
> Key: FLINK-20788
> URL: https://issues.apache.org/jira/browse/FLINK-20788
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table SQL / API
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.19.0
>
>
> Currently, it doesn't support to use cube/rollup/grouping sets in the Table 
> API. For the following job:
> {code}
> table.groupBy("cube(a, b)")
> {code}
> It will throw the following exception:
> {code}
> 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)
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2023-03-23 Thread Xintong Song (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Xintong Song updated FLINK-20788:
-
Fix Version/s: 1.18.0
   (was: 1.17.0)

> It doesn't support to use cube/rollup/grouping sets in the Table API
> 
>
> Key: FLINK-20788
> URL: https://issues.apache.org/jira/browse/FLINK-20788
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table SQL / API
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.18.0
>
>
> Currently, it doesn't support to use cube/rollup/grouping sets in the Table 
> API. For the following job:
> {code}
> table.groupBy("cube(a, b)")
> {code}
> It will throw the following exception:
> {code}
> 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)
> {code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2022-05-12 Thread Huang Xingbo (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Huang Xingbo updated FLINK-20788:
-
Fix Version/s: 1.17.0
   (was: 1.16.0)

> It doesn't support to use cube/rollup/grouping sets in the Table API
> 
>
> Key: FLINK-20788
> URL: https://issues.apache.org/jira/browse/FLINK-20788
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table SQL / API
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.17.0
>
>
> Currently, it doesn't support to use cube/rollup/grouping sets in the Table 
> API. For the following job:
> {code}
> table.groupBy("cube(a, b)")
> {code}
> It will throw the following exception:
> {code}
> 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)
> {code}



--
This message was sent by Atlassian Jira
(v8.20.7#820007)

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2022-04-13 Thread Yun Gao (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Yun Gao updated FLINK-20788:

Fix Version/s: 1.16.0

> It doesn't support to use cube/rollup/grouping sets in the Table API
> 
>
> Key: FLINK-20788
> URL: https://issues.apache.org/jira/browse/FLINK-20788
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table SQL / API
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.15.0, 1.16.0
>
>
> Currently, it doesn't support to use cube/rollup/grouping sets in the Table 
> API. For the following job:
> {code}
> table.groupBy("cube(a, b)")
> {code}
> It will throw the following exception:
> {code}
> 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)
> {code}



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2021-09-28 Thread Xintong Song (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Xintong Song updated FLINK-20788:
-
Fix Version/s: (was: 1.14.0)
   1.15.0

> It doesn't support to use cube/rollup/grouping sets in the Table API
> 
>
> Key: FLINK-20788
> URL: https://issues.apache.org/jira/browse/FLINK-20788
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table SQL / API
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.15.0
>
>
> Currently, it doesn't support to use cube/rollup/grouping sets in the Table 
> API. For the following job:
> {code}
> table.groupBy("cube(a, b)")
> {code}
> It will throw the following exception:
> {code}
> 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)
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

[jira] [Updated] (FLINK-20788) It doesn't support to use cube/rollup/grouping sets in the Table API

2021-04-02 Thread Jark Wu (Jira) 


 [ 
https://issues.apache.org/jira/browse/FLINK-20788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jark Wu updated FLINK-20788:

Fix Version/s: (was: 1.13.0)
   1.14.0

> It doesn't support to use cube/rollup/grouping sets in the Table API
> 
>
> Key: FLINK-20788
> URL: https://issues.apache.org/jira/browse/FLINK-20788
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table SQL / API
>Reporter: Dian Fu
>Priority: Major
> Fix For: 1.14.0
>
>
> Currently, it doesn't support to use cube/rollup/grouping sets in the Table 
> API. For the following job:
> {code}
> table.groupBy("cube(a, b)")
> {code}
> It will throw the following exception:
> {code}
> 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)
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)