[Enhancement] Upgrade hudi dependency version to 0.12.1

fe/fe-core/pom.xml

@@ -249,6 +249,12 @@ under the License.
             <groupId>org.apache.iceberg</groupId>
             <artifactId>iceberg-api</artifactId>
             <version>${iceberg.version}</version>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.apache.parquet</groupId>
+                    <artifactId>parquet-format-structures</artifactId>
+                </exclusion>
+            </exclusions>
         </dependency>
 
         <dependency>
@@ -577,13 +583,20 @@ under the License.
         <dependency>
             <groupId>org.apache.hudi</groupId>
             <artifactId>hudi-common</artifactId>
+            <exclusions>
+                <exclusion>
+                    <groupId>io.netty</groupId>
+                    <artifactId>*</artifactId>
+                </exclusion>
+            </exclusions>
         </dependency>
 
         <!-- https://mvnrepository.com/artifact/org.apache.hudi/hudi-hadoop-mr -->
         <dependency>
             <groupId>org.apache.hudi</groupId>
             <artifactId>hudi-hadoop-mr</artifactId>
         </dependency>
+
         <dependency>
             <groupId>com.starrocks</groupId>
             <artifactId>starclient</artifactId>
@@ -703,6 +716,9 @@ under the License.
                     <thriftExecutable>${starrocks.thrift}</thriftExecutable>
                     <thriftSourceRoot>${starrocks.home}/gensrc/thrift</thriftSourceRoot>
                     <generator>java</generator>
+                    <excludes>
+                        <exclude>**/parquet.thrift</exclude>
+                    </excludes>
                 </configuration>
                 <executions>
                     <execution>

fe/fe-core/src/main/java/com/starrocks/sql/analyzer/AlterTableStatementAnalyzer.java

@@ -55,7 +55,6 @@
 import com.starrocks.sql.ast.RollupRenameClause;
 import com.starrocks.sql.ast.TableRenameClause;
 import com.starrocks.sql.common.MetaUtils;
-import edu.umd.cs.findbugs.annotations.CheckForNull;
 
 import java.util.List;
 import java.util.Map;
@@ -112,7 +111,6 @@ public Void visitTableRenameClause(TableRenameClause clause, ConnectContext cont
 
         @Override
         public Void visitModifyTablePropertiesClause(ModifyTablePropertiesClause clause, ConnectContext context) {
-            @CheckForNull
             Map<String, String> properties = clause.getProperties();
             if (properties.isEmpty()) {
                 ErrorReport.reportSemanticException(ErrorCode.ERR_COMMON_ERROR, "Properties is not set");

fe/fe-core/src/main/java/com/starrocks/sql/ast/ModifyTablePropertiesClause.java

@@ -18,6 +18,7 @@
 import com.starrocks.alter.AlterOpType;
 
 import java.util.Map;
+import javax.annotation.Nonnull;
 
 // clause which is used to modify table properties
 public class ModifyTablePropertiesClause extends AlterTableClause {
@@ -37,6 +38,7 @@ public void setNeedTableStable(boolean needTableStable) {
     }
 
     @Override
+    @Nonnull
     public Map<String, String> getProperties() {
         return this.properties;
     }

fe/pom.xml

@@ -49,7 +49,7 @@ under the License.
         <parquet.version>1.10.1</parquet.version>
         <hadoop.version>3.3.3</hadoop.version>
         <skip.plugin>false</skip.plugin>
-        <hudi.version>0.10.1</hudi.version>
+        <hudi.version>0.12.1</hudi.version>
         <hive-apache.version>3.1.2-13</hive-apache.version>
         <dlf-metastore-client.version>0.2.14</dlf-metastore-client.version>
         <sonar.organization>starrocks</sonar.organization>

java-extensions/hudi-reader/pom.xml

@@ -16,9 +16,12 @@
         <maven.compiler.target>8</maven.compiler.target>
         <java-extensions.home>${basedir}/../</java-extensions.home>
         <slf4j.version>1.7.32</slf4j.version>
-        <hudi.version>0.11.1</hudi.version>
+        <presto.hadoop.version>2.7.4-9</presto.hadoop.version>
+        <presto.hive.version>3.0.0-8</presto.hive.version>
+        <hudi.version>0.12.1</hudi.version>
         <fasterxml.version>2.13.4</fasterxml.version>
         <fasterxml.jackson.databind.version>2.13.4.1</fasterxml.jackson.databind.version>
+        <esotericsoftware.kryo.shaded.version>4.0.2</esotericsoftware.kryo.shaded.version>
     </properties>
 
     <dependencies>
@@ -63,7 +66,7 @@
         <dependency>
             <groupId>com.facebook.presto.hive</groupId>
             <artifactId>hive-apache</artifactId>
-            <version>3.0.0-8</version>
+            <version>${presto.hive.version}</version>
             <exclusions>
                 <exclusion>
                     <groupId>org.slf4j</groupId>
@@ -75,7 +78,7 @@
         <dependency>
             <groupId>com.facebook.presto.hadoop</groupId>
             <artifactId>hadoop-apache2</artifactId>
-            <version>2.7.4-9</version>
+            <version>${presto.hadoop.version}</version>
             <exclusions>
                 <exclusion>
                     <groupId>org.slf4j</groupId>
@@ -111,7 +114,7 @@
         <dependency>
             <groupId>com.esotericsoftware</groupId>
             <artifactId>kryo-shaded</artifactId>
-            <version>4.0.2</version>
+            <version>${esotericsoftware.kryo.shaded.version}</version>
         </dependency>
 
     </dependencies>

java-extensions/hudi-reader/src/main/java/com/starrocks/hudi/reader/HudiSliceScannerFactory.java

@@ -42,7 +42,7 @@ public class HudiSliceScannerFactory implements ScannerFactory {
 
     /**
      * Hudi scanner uses own independent classloader to find all classes
-     * due to hadoop class conflicts with JNI launcher of libhdfs (hadoop-3.x).
+     * due to hadoop version (hadoop-2.x) conflicts with JNI launcher of libhdfs (hadoop-3.x).
      */
     @Override
     public Class getScannerClass() throws ClassNotFoundException {

java-extensions/jni-connector/src/main/java/com/starrocks/jni/connector/ConnectorScanner.java

@@ -35,7 +35,8 @@
  * open();
  * do {
  *     int rows = getNext();
- *     if (rows < fetchSize) {
+ *     // do something...
+ *     if (rows == 0) {
  *         break;
  *     }
  * } while (true);

thirdparty/build-thirdparty.sh

@@ -31,7 +31,7 @@ set -e
 curdir=`dirname "$0"`
 curdir=`cd "$curdir"; pwd`
 
-export STARROCKS_HOME=$curdir/..
+export STARROCKS_HOME=${STARROCKS_HOME:-$curdir/..}
 export TP_DIR=$curdir
 
 # include custom environment variables