From 2dcb3f0062074b59676bb65b0afee86994571fd6 Mon Sep 17 00:00:00 2001
From: Danny Chan <yuzhao.cyz@gmail.com>
Date: Sat, 11 Dec 2021 14:40:57 +0800
Subject: [PATCH] [HUDI-2985] Shade jackson for hudi flink bundle jar (#4284)

---
 .../org/apache/hudi/sink/StreamWriteOperatorCoordinator.java  | 3 +++
 packaging/hudi-flink-bundle/pom.xml                           | 4 ++++
 2 files changed, 7 insertions(+)

diff --git a/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java b/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
index c1b56b95f..d72eb1206 100644
--- a/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
+++ b/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
@@ -377,6 +377,9 @@ public class StreamWriteOperatorCoordinator
     if (allEventsReceived()) {
       // start to commit the instant.
       commitInstant(this.instant);
+      // The executor thread inherits the classloader of the #handleEventFromOperator
+      // caller, which is a AppClassLoader.
+      Thread.currentThread().setContextClassLoader(getClass().getClassLoader());
       // sync Hive if is enabled in batch mode.
       syncHiveIfEnabled();
     }
diff --git a/packaging/hudi-flink-bundle/pom.xml b/packaging/hudi-flink-bundle/pom.xml
index 443eb42cd..a2f91491e 100644
--- a/packaging/hudi-flink-bundle/pom.xml
+++ b/packaging/hudi-flink-bundle/pom.xml
@@ -227,6 +227,10 @@
                   <pattern>com.esotericsoftware.kryo.</pattern>
                   <shadedPattern>${flink.bundle.shade.prefix}com.esotericsoftware.kryo.</shadedPattern>
                 </relocation>
+                <relocation>
+                  <pattern>com.fasterxml.jackson.</pattern>
+                  <shadedPattern>${flink.bundle.shade.prefix}com.fasterxml.jackson.</shadedPattern>
+                </relocation>
               </relocations>
               <filters>
                 <filter>