[FLINK-20625][pubsub,e2e] Update parameter for EnumeratorState

RyanSkraba · MartijnVisser · commit 81775b05a785 · 2023-06-28T09:07:42.000+02:00
diff --git a/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/source/enumerator/PubSubSourceEnumerator.java b/flink-connector-gcp-pubsub/src/main/java/org/apache/flink/streaming/connectors/gcp/pubsub/source/enumerator/PubSubSourceEnumerator.java
@@ -68,7 +68,7 @@ public void addReader(int subtaskId) {
      * @throws Exception
      */
     @Override
-    public PubSubEnumeratorState snapshotState() throws Exception {
+    public PubSubEnumeratorState snapshotState(long checkpointId) throws Exception {
         return new PubSubEnumeratorState();
     }
 

Original file line number	Diff line number	Diff line change
`@@ -68,7 +68,7 @@ public void addReader(int subtaskId) {`
`68`	`68`	`* @throws Exception`
`69`	`69`	`*/`
`70`	`70`	`@Override`
`71`		`- public PubSubEnumeratorState snapshotState() throws Exception {`
	`71`	`+ public PubSubEnumeratorState snapshotState(long checkpointId) throws Exception {`
`72`	`72`	`return new PubSubEnumeratorState();`
`73`	`73`	`}`
`74`	`74`