测试

ad/hive_test.py

@@ -25,7 +25,7 @@ if __name__ == '__main__':
             if reader.count < num:
                 print("error")
             # 获取字段名称
-            column_names = reader.schema.names
+            column_names = [col.name for col in reader._schema.columns]
             # 获取查询结果数据
             data = []
             for record in reader: