[hotfix] Make fields transient in TwoPhaseCommitSinkFunction

Pance · Nov 1, 2017 · 944a63c · 944a63c
1 parent 0e97220
commit 944a63c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java b/...0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
@@ -179,7 +179,7 @@ public enum Semantic {
  /**
  * Hint for picking next transactional id.
  */
- private NextTransactionalIdHint nextTransactionalIdHint;
+ private transient NextTransactionalIdHint nextTransactionalIdHint;
 
  /**
  * User defined properties for the Producer.

diff --git a/...c/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java b/...c/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
@@ -65,10 +65,10 @@ public abstract class TwoPhaseCommitSinkFunction<IN, TXN, CONTEXT>
  protected final LinkedHashMap<Long, TXN> pendingCommitTransactions = new LinkedHashMap<>();
 
  @Nullable
- protected TXN currentTransaction;
- protected Optional<CONTEXT> userContext;
+ protected transient TXN currentTransaction;
+ protected transient Optional<CONTEXT> userContext;
 
- protected ListState<State<TXN, CONTEXT>> state;
+ protected transient ListState<State<TXN, CONTEXT>> state;
 
  /**
  * Use default {@link ListStateDescriptor} for internal state serialization. Helpful utilities for using this