lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2985] Shade jackson for hudi flink bundle jar (#4284)

Browse Source
This commit is contained in:
Danny Chan
2021-12-11 14:40:57 +08:00
committed by GitHub
parent 9bdcee00c0
commit 2dcb3f0062
2 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java
View File

@@ -377,6 +377,9 @@ public class StreamWriteOperatorCoordinator
if (allEventsReceived()) { if (allEventsReceived()) {
// start to commit the instant. // start to commit the instant.
commitInstant(this.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. // sync Hive if is enabled in batch mode.
syncHiveIfEnabled(); syncHiveIfEnabled();
} }

4
packaging/hudi-flink-bundle/pom.xml
View File

@@ -227,6 +227,10 @@
<pattern>com.esotericsoftware.kryo.</pattern> <pattern>com.esotericsoftware.kryo.</pattern>
<shadedPattern>${flink.bundle.shade.prefix}com.esotericsoftware.kryo.</shadedPattern> <shadedPattern>${flink.bundle.shade.prefix}com.esotericsoftware.kryo.</shadedPattern>
</relocation> </relocation>
<relocation>
<pattern>com.fasterxml.jackson.</pattern>
<shadedPattern>${flink.bundle.shade.prefix}com.fasterxml.jackson.</shadedPattern>
</relocation>
</relocations> </relocations>
<filters> <filters>
<filter> <filter>