Hi Flink devs,

Quick question: Why does *TableEnvironmentImpl#*TemporarySystemFunction*
doesn't offer an API with *ignoreIfExists* - basically to
support idempotent registration of UDF functions unlike createFunction that
offers an API with *ignoreExists?*

Want to understand if there is any nuance to it that I'm missing or is it
simply just a new API that needs to be added?

Side question: does re-registration of a same UDF function can cause
inconsistent behavior in terms of classloading that fails with "Caused by:
org.apache.flink.table.api.ValidationException: Invalid argument type at
position 0. Data type X expected but X passed."

Is this a different manifestation of the same X cannot be cast to X
exception
<https://nightlies.apache.org/flink/flink-docs-master/docs/ops/debugging/debugging_classloading/#x-cannot-be-cast-to-x-exceptions>
?

Regards
Venkata krishnan

Reply via email to