From e1aa0369887a598f084bfe934d0c7b4c6cca0a80 Mon Sep 17 00:00:00 2001 From: Shunping Huang Date: Fri, 17 Apr 2026 23:54:39 -0400 Subject: [PATCH 1/2] Update hbase version to fix netty CVEs. --- sdks/java/io/hbase/build.gradle | 2 +- sdks/java/io/iceberg/hive/build.gradle | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sdks/java/io/hbase/build.gradle b/sdks/java/io/hbase/build.gradle index a361a593b4fe..c41e7edb3177 100644 --- a/sdks/java/io/hbase/build.gradle +++ b/sdks/java/io/hbase/build.gradle @@ -34,7 +34,7 @@ test { jvmArgs "-Dtest.build.data.basedirectory=build/test-data" } -def hbase_version = "2.6.3-hadoop3" +def hbase_version = "2.6.5-hadoop3" dependencies { implementation library.java.vendored_guava_32_1_2_jre diff --git a/sdks/java/io/iceberg/hive/build.gradle b/sdks/java/io/iceberg/hive/build.gradle index 11c8118b4bc2..b6f30079cb2e 100644 --- a/sdks/java/io/iceberg/hive/build.gradle +++ b/sdks/java/io/iceberg/hive/build.gradle @@ -26,7 +26,7 @@ description = "Apache Beam :: SDKs :: Java :: IO :: Iceberg :: Hive" ext.summary = "Runtime dependencies needed for Hive catalog integration." def hive_version = "3.1.3" -def hbase_version = "2.6.3-hadoop3" +def hbase_version = "2.6.5-hadoop3" def hadoop_version = "3.4.1" def iceberg_version = "1.6.1" def avatica_version = "1.25.0" From 6d03b38ac4c192436cbd7e59ba2ff97f9ece3559 Mon Sep 17 00:00:00 2001 From: Shunping Huang Date: Sat, 18 Apr 2026 00:23:21 -0400 Subject: [PATCH 2/2] Minor fix hbase test on exception message. --- .../src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java b/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java index b4e0de58cf37..c70a77353d26 100644 --- a/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java +++ b/sdks/java/io/hbase/src/test/java/org/apache/beam/sdk/io/hbase/HBaseIOTest.java @@ -436,7 +436,7 @@ public void testWritingFailsBadElement() throws Exception { thrown.expect(Pipeline.PipelineExecutionException.class); thrown.expectCause(Matchers.instanceOf(IllegalArgumentException.class)); - thrown.expectMessage("No columns to insert"); + thrown.expectMessage("No columns to put"); p.run().waitUntilFinish(); }