[GitHub] flink pull request #4910: [FLINK-7784] [kafka-producer] Don't fail TwoPhaseC...

[pnowojski]

Github user pnowojski commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4910#discussion_r147662205
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
 ---
    @@ -362,4 +483,39 @@ public void setContext(Optional<CONTEXT> context) {
                        this.context = context;
                }
        }
    +
    +   /**
    +    * Adds metadata (currently only the start time of the transaction) to 
the transaction object.
    +    */
    +   @VisibleForTesting
    +   static class TransactionHolder<TXN> {
    --- End diff --
    
    `TransactionWrapper`? 


---