This is an automated email from the ASF dual-hosted git repository.
zouxinyi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from 4783fc09011 [feature](meta-service) Support querying and adjusting rpc
qps limit on meta service (#42413)
add 6c2c36da279 [fix](arrow-flight-sql) Arrow flight server supports data
forwarding when BE uses public vip (#43281)
No new revisions were added by this update.
Summary of changes:
be/src/common/config.cpp | 7 +
be/src/common/config.h | 6 +
.../pipeline/exec/memory_scratch_sink_operator.cpp | 2 +-
be/src/pipeline/exec/result_file_sink_operator.cpp | 8 +-
be/src/pipeline/exec/result_sink_operator.cpp | 19 +-
be/src/runtime/buffer_control_block.cpp | 229 ++++++++++++++--
be/src/runtime/buffer_control_block.h | 58 +++-
be/src/runtime/result_buffer_mgr.cpp | 76 +++---
be/src/runtime/result_buffer_mgr.h | 30 ++-
.../arrow_flight/arrow_flight_batch_reader.cpp | 291 +++++++++++++++++++--
.../arrow_flight/arrow_flight_batch_reader.h | 69 ++++-
be/src/service/arrow_flight/flight_sql_service.cpp | 57 ++--
be/src/service/internal_service.cpp | 60 ++++-
be/src/service/internal_service.h | 5 +
be/src/util/arrow/row_batch.cpp | 11 +-
be/src/util/arrow/row_batch.h | 12 +-
be/src/util/arrow/utils.cpp | 3 +-
be/src/util/doris_metrics.h | 5 +
be/src/vec/sink/varrow_flight_result_writer.cpp | 64 ++---
be/src/vec/sink/varrow_flight_result_writer.h | 16 +-
be/test/runtime/result_buffer_mgr_test.cpp | 13 +-
.../arrowflight/DorisFlightSqlProducer.java | 35 ++-
.../arrowflight/FlightSqlConnectProcessor.java | 14 +-
gensrc/proto/internal_service.proto | 16 ++
24 files changed, 860 insertions(+), 246 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
