测试

ad/pai_flow_operator2.py

@@ -53,7 +53,7 @@ def get_data_from_odps(project, table, num):
             if reader.count < num:
                 return None
             # 获取字段名称
-            column_names = [col.name for col in reader.get_schema().columns]
+            column_names = reader.schema.names
             # 获取查询结果数据
             data = []
             for record in reader: