Remove delta.experimental.ignore-checkpoint-write-failures config #14108
Conversation
There was a problem hiding this comment.
writeCheckpointIfNeeded is called after the write has been "committed", i.e. the transaction log exists.
Let's assume it's an INSERT query. If we now fail it, it can be retried by the calling application, leading to duplicate rows.
IMO we should log unconditionally
@alexjo2144 wdyt?
There was a problem hiding this comment.
What loggin buys us? If so I would make exception message (for which it is more probable that someone would actually read it) more explanatory (that data could have been (or have been) already persisted in the table even though query failed).
Does "otherwise" ever happen? Look it does not, which makes RN text misleading iMO. |
There was a problem hiding this comment.
Add a @DefunctConfig annotation
0c5d0ff to
88c68bd
Compare
plugin/trino-delta-lake/src/main/java/io/trino/plugin/deltalake/DeltaLakeConfig.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Let's capture the reasoning from our conversation, why we don't fail here
88c68bd to
a5e6d92
Compare
a5e6d92 to
372e0f0
Compare
Description
In case of failure while writing checkpoint file error is logged.
Non-technical explanation
Release notes
() This is not user-visible and no release notes are required.
( ) Release notes are required, please propose a release note for me.
(x) Release notes are required, with the following suggested text: