>
> Regarding the warning message, I think you could just ignore it. Per my
> understanding, it's saying that it's using a deprecated API of pyarrow.
> However, it should still work.
>
> Regards,
> Dian
>
> [1] https://issues.apache.org/jira/browse/FLINK-26846
>
Hello,
I try to run my flink java job using Python UDF, but i have some
doubt using gauge metrics and vectorized udf on it.
1. i try to create a simple udf like this example on the docs
https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/python/table/metrics/#gauge.
i al
Hello,
Currently, Flink already supports adding Python UDF and using that on Flink
Java job. It can be used on Table API. Can we do the same for creating
custom python function for Datastream transformation and use that on Flink
Java job?
Regards,
Jesry
