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
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