[FLINK-20271] Fix ArrayIndexOutOfBounds for RetractableTopNFunction - ASF JIRA

Attach files

Attach Screenshot

Voters

Watch issue

Watchers

Create sub-task

Link

Clone

Update Comment Author

Replace String in Comment

Update Comment Visibility

Delete Comments

XML

Word

Printable

JSON

Details

Type: Bug
Status: Closed
Priority: Major
Resolution: Fixed
Affects Version/s: 1.11.0, 1.12.0
Fix Version/s: 1.12.0
Component/s: Table SQL / Planner
Labels:
- pull-request-available

Description

We can get the bug by adding the case into the UnitTest RetractableTopNFunctionTest

// Some comments here
	@Test
	public void testCornerCase() throws Exception {
		AbstractTopNFunction func = createFunction(RankType.ROW_NUMBER, new ConstantRankRange(1, 3), false,
				false);
		OneInputStreamOperatorTestHarness<RowData, RowData> testHarness = createTestHarness(func);
		testHarness.open();
		testHarness.processElement(insertRecord("a", 1L, 1));
		testHarness.processElement(insertRecord("a", 2L, 2));
		testHarness.processElement(insertRecord("a", 3L, 2));
		testHarness.processElement(insertRecord("a", 4L, 2));
		testHarness.processElement(insertRecord("a", 5L, 3));
		testHarness.processElement(insertRecord("a", 6L, 4));
		testHarness.processElement(updateBeforeRecord("a", 2L, 2));
		testHarness.close();
	}