cshuo commented on code in PR #13530:
URL: https://github.com/apache/hudi/pull/13530#discussion_r2196829895
##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/event/Correspondent.java:
##########
@@ -108,4 +123,36 @@ public String getInstant() {
return instant;
}
}
+
+ /**
+ * A request for pending checkpoint ids.
+ */
+ public static class PendingCheckpointsRequest implements CoordinationRequest
{
+
+ private PendingCheckpointsRequest() {
+ }
+
+ public static PendingCheckpointsRequest getInstance() {
+ return new PendingCheckpointsRequest();
+ }
+ }
+
+ /**
+ * A response with pending checkpoint ids.
+ */
+ public static class PendingCheckpointsResponse implements
CoordinationResponse {
+ private final Set<Long> ckpIds;
Review Comment:
`ckpIds` should be guaranteed as serializable, note that `Set` doesn't
extends `Serializable`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
