nymore, 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: Freitag, 12. Jun
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
Hello,
I'm writing a test for my custom sink function. The function is stateful
and relies on checkpoint restores for maintaining consistency with the
external system that it's writing to. For integration testing of the sink
function, I have a MiniCluster based environment inside a single JVM
