This is an automated email from the ASF dual-hosted git repository.

FrankChen021 pushed a commit to branch codex/codeql-warning-arithmetic
in repository https://gitbox.apache.org/repos/asf/druid.git

commit 67f9a604b7ac368297ae88e0c3a705b0279c454c
Author: Frank Chen <[email protected]>
AuthorDate: Thu Sep 10 09:44:50 2026 +0800

    test: address review feedback
---
 .../java/org/apache/druid/segment/data/CompressionStrategyTest.java   | 1 +
 .../java/org/apache/druid/segment/serde/HyperUniquesSerdeForTest.java | 4 +++-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/processing/src/test/java/org/apache/druid/segment/data/CompressionStrategyTest.java
 
b/processing/src/test/java/org/apache/druid/segment/data/CompressionStrategyTest.java
index 320f5103a15..20aace6523c 100644
--- 
a/processing/src/test/java/org/apache/druid/segment/data/CompressionStrategyTest.java
+++ 
b/processing/src/test/java/org/apache/druid/segment/data/CompressionStrategyTest.java
@@ -92,6 +92,7 @@ public class CompressionStrategyTest
     }
   }
 
+  @Test
   @org.junit.jupiter.api.Timeout(value = 60_000L, unit = 
java.util.concurrent.TimeUnit.MILLISECONDS)
   public void testConcurrency() throws Exception
   {
diff --git 
a/processing/src/test/java/org/apache/druid/segment/serde/HyperUniquesSerdeForTest.java
 
b/processing/src/test/java/org/apache/druid/segment/serde/HyperUniquesSerdeForTest.java
index dfa9c283eb2..df56f7da858 100644
--- 
a/processing/src/test/java/org/apache/druid/segment/serde/HyperUniquesSerdeForTest.java
+++ 
b/processing/src/test/java/org/apache/druid/segment/serde/HyperUniquesSerdeForTest.java
@@ -117,7 +117,9 @@ public class HyperUniquesSerdeForTest extends 
ComplexMetricSerde
       {
         final ByteBuffer readOnlyBuffer = buffer.asReadOnlyBuffer();
         if (numBytes < 0 || numBytes > readOnlyBuffer.remaining()) {
-          throw new IllegalArgumentException("numBytes exceeds the available 
buffer contents");
+          throw new IllegalArgumentException(
+              String.format("Invalid numBytes[%d] for buffer remaining[%d]", 
numBytes, readOnlyBuffer.remaining())
+          );
         }
         readOnlyBuffer.limit(readOnlyBuffer.position() + numBytes);
         return HyperLogLogCollector.makeCollector(readOnlyBuffer);


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to