raminqaf commented on code in PR #27994:
URL: https://github.com/apache/flink/pull/27994#discussion_r3128681275
##########
docs/content/docs/sql/reference/queries/changelog.md:
##########
@@ -52,7 +52,8 @@ SELECT * FROM FROM_CHANGELOG(
'ub', 'UPDATE_BEFORE',
'ua', 'UPDATE_AFTER',
'd', 'DELETE'
- ]]
+ ],]
+ [invalid_op_handling => 'FAIL' | 'SKIP']
Review Comment:
I like the idea and the name! I will apply this.
As a follow-up, I'd propose to lift this into the framework with a new
builder method `BuiltInFunctionDefinition.Builder.withErrorHandling()` that
auto-injects the error_handling system argument, runs the shared FAIL/SKIP
validation, and exposes the resolved mode to runtime via the
`SpecializedContext`.
I would be happy to file a Jira ticket and tackle it in a separate PR if
that direction makes sense to.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
