Hi @walterddr , I guess what fabian means is putting this function in `org.apache.flink.table.expressions.Aggregation`, so that distinct can only be called by an aggregate. In this way, we can even remove the test cases such as `testDistinctOnNonAggregateExpression` since compile error will be thrown directly by the IDE. What do you think?
[ Full content available at: https://github.com/apache/flink/pull/6521 ] This message was relayed via gitbox.apache.org for [email protected]
