I’m facing a:

org.apache.flink.util.SerializedThrowable: io.grpc.StatusRuntimeException: INVALID_ARGUMENT: Some acknowledgement ids in the request were invalid. This could be because the acknowledgement ids have expired or the acknowledgement ids were malformed.

after enabling the exactly_once_delivery in the PubSub subscription.
The application runs fine for around 2 hours then it happens and it crashes.

The subscription’s ack deadline is set to 60s.
Flink’s checkpoint interval is set to 10s.

I have 10 of parallelism and the backpressure is around 2%.

I’m using PubSubSource to connect PubSub and it sinks the info to HDFS.
Flink version is 1.17.2 and Java version is 1.8.

Does anybody has any idea?