henvealf created FLINK-19242:
--------------------------------
Summary: org.apache.flink.table.api.ValidationException: Cannot
resolve field
Key: FLINK-19242
URL: https://issues.apache.org/jira/browse/FLINK-19242
Project: Flink
Issue Type: Bug
Components: Table SQL / API
Affects Versions: 1.11.1
Reporter: henvealf
Hello,
The Code:
{code:java}
val countResult = eventTable
.select($"name", $"product", $"id", $"_event_time")
.window(Tumble over 10.second() on $"_event_time" as "w")
.groupBy( $"id", $"w")
.select(
$"id".count() as("c"), $"id", $"w"
)
{code}
Exception:
{code:java}
Exception in thread "main" org.apache.flink.table.api.ValidationException:
Cannot resolve field [w], input field list:[id, EXPR$0].Exception in thread
"main" org.apache.flink.table.api.ValidationException: Cannot resolve field
[w], input field list:[id, EXPR$0]. at
org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.failForField(ReferenceResolverRule.java:80)
at
org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.lambda$null$3(ReferenceResolverRule.java:75)
at java.util.Optional.orElseThrow(Optional.java:290) at
org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.lambda$null$4(ReferenceResolverRule.java:75)
at java.util.Optional.orElseGet(Optional.java:267) at
org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.lambda$visit$5(ReferenceResolverRule.java:74)
at java.util.Optional.orElseGet(Optional.java:267) at
org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.visit(ReferenceResolverRule.java:71)
at
org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule$ExpressionResolverVisitor.visit(ReferenceResolverRule.java:51)
at
org.apache.flink.table.expressions.ApiExpressionVisitor.visit(ApiExpressionVisitor.java:31)
at
org.apache.flink.table.expressions.UnresolvedReferenceExpression.accept(UnresolvedReferenceExpression.java:60)
at
org.apache.flink.table.expressions.resolver.rules.ReferenceResolverRule.lambda$apply$0(ReferenceResolverRule.java:47)
at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
at
java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1382)
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.ReferenceResolverRule.apply(ReferenceResolverRule.java:48)
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
org.apache.flink.table.expressions.resolver.ExpressionResolver.resolve(ExpressionResolver.java:178)
at
org.apache.flink.table.operations.utils.OperationTreeBuilder.projectInternal(OperationTreeBuilder.java:191)
at
org.apache.flink.table.operations.utils.OperationTreeBuilder.project(OperationTreeBuilder.java:160)
at
org.apache.flink.table.api.internal.TableImpl$WindowGroupedTableImpl.select(TableImpl.java:792)
at
...
Process finished with exit code 1
{code}
Why?
Thanks!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
