in statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/feedback/SubtaskFeedbackKey.java [42:54]
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
SubtaskFeedbackKey<?> that = (SubtaskFeedbackKey<?>) o;
return subtaskIndex == that.subtaskIndex
&& invocationId == that.invocationId
&& attemptId == that.attemptId
&& Objects.equals(pipelineName, that.pipelineName);
}