show logs in notifyCheckpointComplete MessageAcknowledingSourceBase

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

show logs in notifyCheckpointComplete MessageAcknowledingSourceBase

oubrik
Hi,
I implement pub sub as source for flink with MessageAcknowledingSourceBase class. but when  i want to display a simle log in notifyCheckpointComplete method nothing having. Processing finished with success but in deplucat i need to ack theses messages from pub sub with notifyCheckpointComplete .
Any help will be appreciated .

Regards