Skip to content

Commit

Permalink
MINOR: Add missing test tag to UnifiedLogTest.scala (#18794)
Browse files Browse the repository at this point in the history
Reviewers: Chia-Ping Tsai <[email protected]>
  • Loading branch information
jolshan authored Feb 4, 2025
1 parent 42e7cbb commit 00dddee
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions core/src/test/scala/unit/kafka/log/UnifiedLogTest.scala
Original file line number Diff line number Diff line change
Expand Up @@ -3624,6 +3624,7 @@ class UnifiedLogTest {
assertThrows(classOf[OffsetOutOfRangeException], () => log.maybeIncrementLogStartOffset(26L, LogStartOffsetIncrementReason.ClientRecordDeletion))
}

@Test
def testBackgroundDeletionWithIOException(): Unit = {
val logConfig = LogTestUtils.createLogConfig(segmentBytes = 1024 * 1024)
val log = createLog(logDir, logConfig)
Expand Down Expand Up @@ -3683,6 +3684,7 @@ class UnifiedLogTest {
assertEquals(None, log.maybeUpdateHighWatermark(101L))
}

@Test
def testEnableRemoteLogStorageOnCompactedTopics(): Unit = {
var logConfig = LogTestUtils.createLogConfig()
var log = createLog(logDir, logConfig)
Expand Down Expand Up @@ -3936,6 +3938,7 @@ class UnifiedLogTest {
assertEquals(VerificationGuard.SENTINEL, log.verificationGuard(producerId))
}

@Test
def testNextTransactionVerificationGuardNotCleared(): Unit = {
val producerStateManagerConfig = new ProducerStateManagerConfig(86400000, true)

Expand Down

0 comments on commit 00dddee

Please sign in to comment.