With the help from Dian and friends, it turns out the root cause is:
When it `create_temporary_function`, it is in the default catalog. However,
when it `execute_sql(TRANSFORM)`, it is in the "hive" catalog. A function
defined as a temporary function in catalog "default" is not accessible from
cat
Hi Dian,
I changed the udf to:
```python
@udf(
input_types=[DataTypes.BIGINT(), DataTypes.BIGINT()],
result_type=DataTypes.BIGINT(),
)
def add(i, j):
return i + j
```
But I still get the same error.
On Tue, May 18, 2021 at 5:47 PM Dian Fu wrote:
> Hi Yik San,
>
> The expected input types for
Hi Yik San,
The expected input types for add are DataTypes.INT, however, the schema of
aiinfra.mysource is: a bigint and b bigint.
Regards,
Dian
> 2021年5月18日 下午5:38，Yik San Chan 写道：
>
> Hi,
>
> I have a PyFlink script that fails to use a simple UDF. The full script can
> be found below:
>
