Hi, quick question: is the close method in sinks, e.g. BucketingSink, called when a job gets cancelled or stopped?
We're trying to have the following: A custom stoppable streaming source with a modified BucketingSink which moves the files from ephemeral storage to S3 Frankfurt upon the closing of part files. Best, Mihail
