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

2023-09-19 Thread Evgeniy Lyutikov
@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

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

FlinkML 'DenseVector' object has no attribute 'get_fields_by_names'

2023-09-18 Thread Evgeniy Lyutikov
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(