[ https://issues.apache.org/jira/browse/FLINK-19242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
henvealf closed FLINK-19242. ---------------------------- Resolution: Fixed My problem. It worked after Changed the following 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".end() ){code} change $"w" to $"w".end() in select > 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 > Priority: Major > > Hello, > Planner: Blink > 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)