Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4919#discussion_r147711564
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/sink/TwoPhaseCommitSinkFunction.java
---
@@ -361,5 +376,247 @@ public void setPendingCommitTransactions(List<TXN>
pendingCommitTransactions) {
public void setContext(Optional<CONTEXT> context) {
this.context = context;
}
+
+ @Override
+ public boolean equals(Object o) {
+ if (this == o) {
+ return true;
+ }
+ if (o == null || getClass() != o.getClass()) {
+ return false;
+ }
+
+ State<?, ?> state = (State<?, ?>) o;
+
--- End diff --
I used IntelliJ to generate those. :sweat_smile:
---
