Checkpoint 59 - Bump hudi version to 1.1.0

Author: voonhous

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/pom.xml

@@ -31,7 +31,7 @@ limitations under the License.
     <name>flink-cdc-pipeline-connector-hudi</name>
 
     <properties>
-        <hudi.version>1.2.0-SNAPSHOT</hudi.version>
+        <hudi.version>1.1.0</hudi.version>
         <hadoop.version>2.10.2</hadoop.version>
         <mockito.version>3.4.6</mockito.version>
         <metrics.version>4.1.1</metrics.version>
@@ -314,9 +314,7 @@ limitations under the License.
                                     <include>javax.servlet:javax.servlet-api</include>
                                     <include>org.apache.httpcomponents:*</include>
 
-<!--                                    <include>org.apache.flink:${flink.hadoop.compatibility.artifactId}</include>-->
                                     <include>org.apache.flink:flink-json</include>
-<!--                                    <include>org.apache.flink:${flink.parquet.artifactId}</include>-->
                                     <include>org.apache.flink:flink-metrics-dropwizard</include>
 
                                     <include>org.apache.hive:hive-common</include>
@@ -335,7 +333,6 @@ limitations under the License.
                                     <include>commons-io:commons-io</include>
                                     <include>org.openjdk.jol:jol-core</include>
 
-                                    <!-- added by voon during flink-cdc testing -->
                                     <include>com.fasterxml.jackson.module:jackson-module-afterburner</include>
                                     <include>io.airlift:aircompressor</include>
 
@@ -372,6 +369,8 @@ limitations under the License.
                                         <exclude>META-INF/*.SF</exclude>
                                         <exclude>META-INF/*.DSA</exclude>
                                         <exclude>META-INF/*.RSA</exclude>
+                                        <!-- Prevent Error: packaged jar contains files with incompatible licenses -->
+                                        <exclude>META-INF/maven/org.openjdk.jol/jol-core/pom.xml</exclude>
                                     </excludes>
                                 </filter>
                             </filters>

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-hudi/src/main/java/org/apache/flink/cdc/connectors/hudi/sink/function/ExtendedBucketStreamWriteFunction.java

@@ -1,3 +1,20 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 package org.apache.flink.cdc.connectors.hudi.sink.function;
 
 import org.apache.flink.configuration.Configuration;

flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml

@@ -43,7 +43,7 @@ limitations under the License.
         <iceberg.version>1.6.1</iceberg.version>
         <hive.version>2.3.9</hive.version>
         <fluss.version>0.7.0</fluss.version>
-        <hudi.version>1.2.0-SNAPSHOT</hudi.version>
+        <hudi.version>1.1.0</hudi.version>
     </properties>
 
     <dependencies>