Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.11.0, 1.12.0
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(); }
Attachments
Issue Links
- duplicates
-
FLINK-18376 java.lang.ArrayIndexOutOfBoundsException in RetractableTopNFunction
- Closed
- fixes
-
FLINK-19633 Fix ArrayIndexOutOfBoundsException in RetractableTopNFunction
- Closed
- is related to
-
FLINK-20121 Test the upsert-kafka Connector
- Closed
- links to