Re: FlinkML 'DenseVector' object has no attribute 'get_fields_by_names'

2023-09-19 Thread Evgeniy Lyutikov
user@flink.apache.org Тема: Re: FlinkML 'DenseVector' object has no attribute 'get_fields_by_names' Hi Evgeniy, Yes, the reason of the exception is that you are returning an incorrect data type. Flink ML doesn’t have a data type for `DenseVector` but it pr

Re: FlinkML 'DenseVector' object has no attribute 'get_fields_by_names'

2023-09-18 Thread Xin Jiang
Hi Evgeniy, Yes, the reason of the exception is that you are returning an incorrect data type. Flink ML doesn’t have a data type for `DenseVector` but it provides a function called `pyflink.ml.functions.array_to_vector` which returns an `Expression`. So maybe you can modify your UDF to union mu