@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 provides a
function called
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
Hello community!
I'm trying to use FlinkML to train a model on data from a PostgreSQL table and
I get an error when I try to view the output table after model
AttributeError: 'DenseVector' object has no attribute 'get_fields_by_names'
My code:
# Create train source table
t_env.execute_sql(