[BEAM-12054] Mutator.close() has to be moved to @FinishBundle in WriteFn and DeleteFn

• Type: Bug
• Status: Resolved
• Priority: P1
• Resolution: Fixed
• Fix Version/s: 2.29.0
• Component/s: io-java-cassandra
• Assignee: Alexey Romanenko
• Reporter: Alexey Romanenko
• Created: 25/Mar/21 18:42
• Updated: 30/Mar/21 18:54
• Resolved: 26/Mar/21 17:04

Description

Since writer.close() contains a business logic and @TearDown is not guaranteed to call, it must be moved to @FinishBundle. The same thing about DeleteFn.

Details are here:

https://lists.apache.org/thread.html/rfcc0df0c5d09699033662c0eb8bcc86de9cc5b4923a50da81700569d%40%3Cdev.beam.apache.org%3E

Issue Links

• links to: GitHub Pull Request #14346