[ https://issues.apache.org/jira/browse/HUDI-7450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ethan Guo updated HUDI-7450: ---------------------------- Fix Version/s: 0.15.0 1.0.0 > Fix invalid kafka offset range bug in KafkaOffsetGen.computeOffsetRanges > ------------------------------------------------------------------------ > > Key: HUDI-7450 > URL: https://issues.apache.org/jira/browse/HUDI-7450 > Project: Apache Hudi > Issue Type: Bug > Components: deltastreamer > Reporter: Vinish Reddy > Assignee: Vinish Reddy > Priority: Major > Labels: pull-request-available > Fix For: 0.15.0, 1.0.0 > > > The offset computation fails with invalid offset range for the following edge > case. > ~@Test~ > ~public void testBug() {~ > ~int[] partitions = new int[] \{0, 1, 2, 3, 4};~ > ~long[] committedOffsets =~ > ~new long[] \{76888767, 76725043, 76899767, 76833267, 76952055};~ > ~long[] latestOffsets =~ > ~new long[] \{77005407, 76768151, 76985456, 76917973, 77080447};~ > ~OffsetRange[] ranges =~ > ~KafkaOffsetGen.CheckpointUtils.computeOffsetRanges(~ > ~makeOffsetMap(partitions, committedOffsets),~ > ~makeOffsetMap(partitions, latestOffsets),~ > ~400000,~ > ~20);~ > ~long totalNewMsgs = > KafkaOffsetGen.CheckpointUtils.totalNewMessages(ranges);~ > ~assertEquals(400000, totalNewMsgs);~ > ~for (OffsetRange range : ranges) {~ > ~if (range.fromOffset() > range.untilOffset()) {~ > ~throw new IllegalArgumentException("Invalid offset range " + range);~ > ~}~ > ~}~ > ~}~ -- This message was sent by Atlassian Jira (v8.20.10#820010)