## What is the purpose of the change Fixes the key validation for SQL queries with group window aggregates that are emitted to an `UpsertStreamTableSink`.
## Brief change log * Handle window properties (start, end, rowtime) in one equivalence group because all property attributes identify the same window. * Add tests for SQL `INSERT INTO` of different result types to different types of table sinks. ## Verifying this change * Run the added tests. ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): **no** - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: **no** - The serializers: **no** - The runtime per-record code paths (performance sensitive): **no** - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: **no** - The S3 file system connector: **no** ## Documentation - Does this pull request introduce a new feature? **no** - If yes, how is the feature documented? **n/a** [ Full content available at: https://github.com/apache/flink/pull/6641 ] This message was relayed via gitbox.apache.org for [email protected]
