Make mailboxExecutorAdapter transient.

apache · Aug 29, 2022 · 29b3d89 · 29b3d89
1 parent d04ac98
commit 29b3d89
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactFunction.java b/...ink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactFunction.java
@@ -81,7 +81,7 @@ public class CompactFunction extends ProcessFunction<CompactionPlanEvent, Compac
    * It's the same thread that runs processElement. Use this executor to send compaction commit events to downstream,
    * avoiding collector.collect being called asynchronously.
    */
-  private final MailboxExecutorAdapter mailboxExecutorAdapter;
+  private final transient MailboxExecutorAdapter mailboxExecutorAdapter;
 
   public CompactFunction(Configuration conf, MailboxExecutorAdapter mailboxExecutorAdapter) {
     this.conf = conf;