Skip to content

Commit dd860aa

Browse files
committed
fix failed tests
1 parent 29fc504 commit dd860aa

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/plan/metadata/FlinkRelMdUniqueGroupsTest.scala

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -313,7 +313,6 @@ class FlinkRelMdUniqueGroupsTest extends FlinkRelMdHandlerTestBase {
313313
@Test
314314
def testGetUniqueGroupsOnWindowAgg(): Unit = {
315315
Array(logicalWindowAgg, flinkLogicalWindowAgg,
316-
batchLocalWindowAgg,
317316
batchGlobalWindowAggWithoutLocalAgg,
318317
batchGlobalWindowAggWithLocalAgg).foreach { agg =>
319318
assertEquals(ImmutableBitSet.of(0, 1, 2, 3, 4, 5, 6),
@@ -327,9 +326,10 @@ class FlinkRelMdUniqueGroupsTest extends FlinkRelMdHandlerTestBase {
327326
assertEquals(ImmutableBitSet.of(0, 1, 2),
328327
mq.getUniqueGroups(agg, ImmutableBitSet.of(0, 1, 2)))
329328
}
329+
assertEquals(ImmutableBitSet.of(0, 1, 2, 3),
330+
mq.getUniqueGroups(batchLocalWindowAgg, ImmutableBitSet.of(0, 1, 2, 3)))
330331

331332
Array(logicalWindowAggWithAuxGroup, flinkLogicalWindowAggWithAuxGroup,
332-
batchLocalWindowAggWithAuxGroup,
333333
batchGlobalWindowAggWithoutLocalAggWithAuxGroup,
334334
batchGlobalWindowAggWithLocalAggWithAuxGroup).foreach { agg =>
335335
assertEquals(ImmutableBitSet.of(1),
@@ -340,7 +340,13 @@ class FlinkRelMdUniqueGroupsTest extends FlinkRelMdHandlerTestBase {
340340
mq.getUniqueGroups(agg, ImmutableBitSet.of(0, 1, 2)))
341341
assertEquals(ImmutableBitSet.of(0, 1, 2, 3),
342342
mq.getUniqueGroups(agg, ImmutableBitSet.of(0, 1, 2, 3)))
343+
assertEquals(ImmutableBitSet.of(0, 1, 2, 3, 4, 5, 6),
344+
mq.getUniqueGroups(agg, ImmutableBitSet.of(0, 1, 2, 3, 4, 5, 6)))
343345
}
346+
assertEquals(ImmutableBitSet.of(0),
347+
mq.getUniqueGroups(batchLocalWindowAggWithAuxGroup, ImmutableBitSet.of(0, 1)))
348+
assertEquals(ImmutableBitSet.of(0, 1, 2),
349+
mq.getUniqueGroups(batchLocalWindowAggWithAuxGroup, ImmutableBitSet.of(0, 1, 2)))
344350
}
345351

346352
@Test

0 commit comments

Comments
 (0)