sages anymore, so all
data will be written and I can run my assertions after the "stopWithSavepoint"
line of code as this runs synchronously.
Hope that helps.
Best regards
Theo
Von: "David Anderson"
An: "Abhishek Rai"
CC: "user"
Gesendet: F
You can study LocalStreamingFileSinkTest [1] for an example of how to
approach this. You can use the test harnesses [2], keeping in mind that
- initializeState is called during instance creation
- the provided context indicates if state is being restored from a snapshot
- snapshot is called when t
