Details
-
Type:
Bug
-
Status: Resolved
-
Priority:
Major
-
Resolution: Duplicate
-
Affects Version/s: 0.16.0
-
Fix Version/s: None
-
Component/s: None
-
Labels:None
Description
FileSystemWriter.write() catches IOExceptions thrown by it's FileAppender, but it doesn't catch RuntimeExceptions. This can cause bad behavior. For example, if you were using the DurableParquetAppender and you close the FileSystemWriter after you failed a write(), you'd end up deleting the Avro file which may or may not cause data loss depending on where the RuntimeException was thrown and how the user application tried to handle individual write failures.