Re: Python UDF Gauge Metrics not working & error log on Vectorized UDF

2022-03-24 Thread Jesry Pandawa
Hi Dian, Thanks for the confirmation. Regards, Jesry Pada tanggal Kam, 24 Mar 2022 pukul 19.32 Dian Fu menulis: > Hi Jesry, > > Regarding the gauge metrics, I have verified that it's a bug introduced > when bumping the Beam version. I have opened a ticket [1] to track it. > > Regarding the wa

Re: Python UDF Gauge Metrics not working & error log on Vectorized UDF

2022-03-24 Thread Dian Fu
Hi Jesry, Regarding the gauge metrics, I have verified that it's a bug introduced when bumping the Beam version. I have opened a ticket [1] to track it. 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.

Python UDF Gauge Metrics not working & error log on Vectorized UDF

2022-03-22 Thread Jesry Pandawa
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