Doris 3.0,3个BE,数据表使用了分区,数据比较均匀,使用Flight SQL数据查询只返回了1/3的数据量。同样的SQL使用MySQL客户端连接doris,查询可以看到全部数据,是FE或BE配置的配置问题?还是其他,请大佬帮忙看下。
代码如下:
import adbc_driver_manager
import adbc_driver_flightsql.dbapi as flight_sql
with flight_sql.connect(uri="grpc://192.168.25.87:9070", db_kwargs={
adbc_driver_manager.DatabaseOptions.USERNAME.value: "xxxx",
adbc_driver_manager.DatabaseOptions.PASSWORD.value: "xxxx"
}) as conn:
cursor = conn.cursor()
cursor.execute("use xxx;")
sql = "select * from table_name;"
cursor.execute(sql)
dd = cursor.fetch_df()
print(dd)
此外,执行代码:
partitions, schema = cursor.adbc_execute_partitions(sql)
print(partitions)
返回的partitions,里面也总是只包含一个BE节点信息。