From 7b39acd554d4f06aa0673fe17af432f4c8dd3d07 Mon Sep 17 00:00:00 2001 From: yan zhang Date: Sat, 31 May 2025 00:34:33 +0800 Subject: [PATCH] [Enhancement] upgrade hudi-common and fix CVEs (#59501) Upgrade hudi-common package so we can keep fixing latest CVEs. Signed-off-by: yan zhang --- .../java/com/starrocks/catalog/HudiTable.java | 2 +- .../connector/hudi/HudiRemoteFileIO.java | 3 +- fe/pom.xml | 36 ++++++++++++++++--- java-extensions/hudi-reader/pom.xml | 2 +- java-extensions/pom.xml | 8 +++++ trivy.yaml | 4 --- 6 files changed, 44 insertions(+), 11 deletions(-) diff --git a/fe/fe-core/src/main/java/com/starrocks/catalog/HudiTable.java b/fe/fe-core/src/main/java/com/starrocks/catalog/HudiTable.java index 11429c6ddf3..5ab0d1a2ff1 100644 --- a/fe/fe-core/src/main/java/com/starrocks/catalog/HudiTable.java +++ b/fe/fe-core/src/main/java/com/starrocks/catalog/HudiTable.java @@ -298,7 +298,7 @@ public class HudiTable extends Table { } if (tableType == HudiTableType.MOR) { - tHudiTable.setInstant_time(lastInstant == null ? "" : lastInstant.getTimestamp()); + tHudiTable.setInstant_time(lastInstant == null ? "" : lastInstant.getCompletionTime()); } tHudiTable.setHive_column_names(hudiProperties.get(HUDI_TABLE_COLUMN_NAMES)); diff --git a/fe/fe-core/src/main/java/com/starrocks/connector/hudi/HudiRemoteFileIO.java b/fe/fe-core/src/main/java/com/starrocks/connector/hudi/HudiRemoteFileIO.java index 4d55bfae595..8e933eae7e1 100644 --- a/fe/fe-core/src/main/java/com/starrocks/connector/hudi/HudiRemoteFileIO.java +++ b/fe/fe-core/src/main/java/com/starrocks/connector/hudi/HudiRemoteFileIO.java @@ -118,7 +118,8 @@ public class HudiRemoteFileIO implements RemoteFileIO { } Iterator hoodieFileSliceIterator = scanContext.hudiFsView - .getLatestMergedFileSlicesBeforeOrOn(partitionName, scanContext.hudiLastInstant.getTimestamp()).iterator(); + .getLatestMergedFileSlicesBeforeOrOn(partitionName, scanContext.hudiLastInstant.getCompletionTime()) + .iterator(); while (hoodieFileSliceIterator.hasNext()) { FileSlice fileSlice = hoodieFileSliceIterator.next(); Optional baseFile = fileSlice.getBaseFile().toJavaOptional(); diff --git a/fe/pom.xml b/fe/pom.xml index 079402bfb66..f2363902bf3 100644 --- a/fe/pom.xml +++ b/fe/pom.xml @@ -50,7 +50,7 @@ under the License. 3.4.1 hadoop3-2.2.26 false - 0.15.0 + 1.0.2 3.1.2-22 0.2.14 starrocks @@ -79,6 +79,8 @@ under the License. 1.2.34 8.5.15 + 1.11.0 + 2.6.2 @@ -796,6 +798,12 @@ under the License. + + commons-beanutils + commons-beanutils + ${commons-beanutils.version} + + org.apache.hadoop hadoop-hdfs @@ -1007,17 +1015,37 @@ under the License. org.apache.zookeeper zookeeper + + + + + org.apache.hbase + hbase-client + ${hbase.version} + - org.apache.hadoop - hadoop-hdfs + org.apache.hbase.thirdparty + hbase-shaded-jetty + + org.apache.hbase.thirdparty + hbase-shaded-netty + + + + + + org.apache.hbase + hbase-server + ${hbase.version} + org.apache.hbase hbase-http org.apache.hbase.thirdparty - hbase-shaded-jetty + hbase-shaded-netty diff --git a/java-extensions/hudi-reader/pom.xml b/java-extensions/hudi-reader/pom.xml index 5dd09911b6c..91f95533f03 100644 --- a/java-extensions/hudi-reader/pom.xml +++ b/java-extensions/hudi-reader/pom.xml @@ -13,7 +13,7 @@ ${basedir}/../ - 0.15.0 + 1.0.2 diff --git a/java-extensions/pom.xml b/java-extensions/pom.xml index b747e81a4b1..d2a09e9ceb3 100644 --- a/java-extensions/pom.xml +++ b/java-extensions/pom.xml @@ -58,6 +58,7 @@ 1.12.0 1.5.4-2 4.0.2 + 1.11.0 @@ -160,6 +161,13 @@ + + + commons-beanutils + commons-beanutils + ${commons-beanutils.version} + + org.apache.hadoop hadoop-hdfs-client diff --git a/trivy.yaml b/trivy.yaml index 6ccabbe2850..542a380caf5 100644 --- a/trivy.yaml +++ b/trivy.yaml @@ -8,10 +8,6 @@ scan: skip-files: # hdfs required - "**/hadoop-client-runtime-3.4.1.jar" - # hudi required - - "**/htrace-core4-4.2.0-incubating.jar" - - "**/hbase-protocol-shaded-2.4.13.jar" - - "**/hbase-shaded-netty-4.1.1.jar" # kudu required - "**/kudu-client-1.17.1.jar" # paimon required