diff --git a/Jenkinsfile b/Jenkinsfile index a463e6c265a3..3b7c634acdee 100755 --- a/Jenkinsfile +++ b/Jenkinsfile @@ -19,7 +19,7 @@ def config = jobConfig { cron = '@weekly' - nodeLabel = 'docker-oraclejdk8' + nodeLabel = 'docker-debian-jdk17' testResultSpecs = ['junit': '**/build/test-results/**/TEST-*.xml'] slackChannel = '#kafka-warn' timeoutHours = 4 diff --git a/clients/src/test/java/org/apache/kafka/common/record/DefaultRecordBatchTest.java b/clients/src/test/java/org/apache/kafka/common/record/DefaultRecordBatchTest.java index 694cf92c7b96..d34240d67416 100644 --- a/clients/src/test/java/org/apache/kafka/common/record/DefaultRecordBatchTest.java +++ b/clients/src/test/java/org/apache/kafka/common/record/DefaultRecordBatchTest.java @@ -403,7 +403,7 @@ public void testStreamingIteratorConsistency(CompressionType compressionType) { } } - //@ParameterizedTest + @ParameterizedTest @EnumSource(value = CompressionType.class) public void testSkipKeyValueIteratorCorrectness(CompressionType compressionType) throws NoSuchAlgorithmException { Header[] headers = {new RecordHeader("k1", "v1".getBytes()), new RecordHeader("k2", null)}; @@ -452,7 +452,7 @@ public void testSkipKeyValueIteratorCorrectness(CompressionType compressionType) } } - //@ParameterizedTest + @ParameterizedTest @MethodSource public void testBufferReuseInSkipKeyValueIterator(CompressionType compressionType, int expectedNumBufferAllocations, byte[] recordValue) { MemoryRecords records = MemoryRecords.withRecords(RecordBatch.MAGIC_VALUE_V2, 0L, @@ -503,7 +503,7 @@ private static Stream testBufferReuseInSkipKeyValueIterator() throws ); } - //@ParameterizedTest + @ParameterizedTest @MethodSource public void testZstdJniForSkipKeyValueIterator(int expectedJniCalls, byte[] recordValue) throws IOException { MemoryRecords records = MemoryRecords.withRecords(RecordBatch.MAGIC_VALUE_V2, 0L,