flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Mihail Vieru <mihail.vi...@zalando.de>
Subject Close method call in sinks
Date Fri, 24 Mar 2017 11:00:29 GMT

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.


View raw message