[FLINK-10259] [table] Fix identification of key attributes for GroupW…

…indows. This closes apache#6641.
laubersder · Sep 18, 2018 · f28b829 · f28b829
1 parent 0794fa8
commit f28b829
Show file tree

Hide file tree

Showing 3 changed files with 408 additions and 30 deletions.
diff --git a/...ies/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala b/...ies/flink-table/src/main/scala/org/apache/flink/table/plan/util/UpdatingPlanChecker.scala
@@ -142,7 +142,8 @@ object UpdatingPlanChecker {
  .map(_.name)
  // we have only a unique key if at least one window property is selected
  if (windowProperties.nonEmpty) {
- Some(groupKeys.map(e => (e, e)) ++ windowProperties.map(e => (e, e)))
+ val windowId = windowProperties.min
+ Some(groupKeys.map(e => (e, e)) ++ windowProperties.map(e => (e, windowId)))
  } else {
  None
  }