This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from a3361df7b9 [Feat](Nereids) support json and jsonb datatype (#24156)
add fc12362a6d [feature-wip](arrow-flight)(step2) FE support Arrow Flight
server (#24314)
No new revisions were added by this update.
Summary of changes:
be/src/agent/heartbeat_server.cpp | 1 +
be/src/common/config.cpp | 2 +-
be/src/common/config.h | 6 +-
be/src/runtime/buffer_control_block.cpp | 1 -
be/src/runtime/result_buffer_mgr.cpp | 40 +--
be/src/runtime/result_buffer_mgr.h | 5 +-
.../arrow_flight/arrow_flight_batch_reader.cpp | 9 +-
be/src/service/doris_main.cpp | 2 +-
be/src/service/internal_service.cpp | 35 +++
be/src/service/internal_service.h | 5 +
be/src/util/arrow/row_batch.cpp | 14 +
be/src/util/arrow/row_batch.h | 3 +
conf/be.conf | 2 +-
conf/fe.conf | 1 +
docs/en/community/developer-guide/be-vscode-dev.md | 1 +
docs/en/community/developer-guide/fe-idea-dev.md | 1 +
.../admin-manual/cluster-management/upgrade.md | 1 +
docs/en/docs/admin-manual/config/be-config.md | 6 +
docs/en/docs/admin-manual/config/fe-config.md | 6 +
.../http-actions/fe/bootstrap-action.md | 3 +
.../admin-manual/http-actions/fe/node-action.md | 1 +
.../maint-monitor/metadata-operation.md | 5 +
docs/en/docs/get-starting/quick-start.md | 1 +
docs/en/docs/install/standard-deployment.md | 1 +
.../sql-functions/table-functions/frontends.md | 2 +
.../community/developer-guide/be-vscode-dev.md | 1 +
.../zh-CN/community/developer-guide/fe-idea-dev.md | 1 +
.../admin-manual/cluster-management/upgrade.md | 1 +
docs/zh-CN/docs/admin-manual/config/be-config.md | 6 +
docs/zh-CN/docs/admin-manual/config/fe-config.md | 6 +
.../http-actions/fe/bootstrap-action.md | 3 +
.../admin-manual/http-actions/fe/node-action.md | 1 +
.../maint-monitor/metadata-operation.md | 4 +
docs/zh-CN/docs/get-starting/quick-start.md | 2 +
docs/zh-CN/docs/install/standard-deployment.md | 1 +
.../sql-functions/table-functions/frontends.md | 2 +
.../main/java/org/apache/doris/common/Config.java | 3 +
fe/fe-core/pom.xml | 71 ++++-
.../src/main/java/org/apache/doris/DorisFE.java | 8 +-
.../apache/doris/common/proc/BackendsProcDir.java | 9 +-
.../doris/common/proc/FrontendsProcNode.java | 4 +-
.../org/apache/doris/common/util/NetUtils.java | 2 +
.../doris/httpv2/rest/BootstrapFinishAction.java | 12 +
.../doris/httpv2/rest/manager/ClusterAction.java | 2 +
.../apache/doris/journal/bdbje/BDBDebugger.java | 3 +-
.../glue/translator/PhysicalPlanTranslator.java | 3 +-
.../apache/doris/planner/DistributedPlanner.java | 1 +
.../org/apache/doris/planner/PlanFragment.java | 9 +-
.../java/org/apache/doris/planner/ResultSink.java | 10 +
.../java/org/apache/doris/qe/ConnectContext.java | 11 +
.../main/java/org/apache/doris/qe/Coordinator.java | 38 +++
.../java/org/apache/doris/qe/PointQueryExec.java | 10 +-
.../main/java/org/apache/doris/qe/QeService.java | 18 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 65 +++-
.../org/apache/doris/rpc/BackendServiceClient.java | 5 +
.../org/apache/doris/rpc/BackendServiceProxy.java | 12 +
.../apache/doris/service/FrontendServiceImpl.java | 1 +
.../service/arrowflight/FlightSqlService.java | 67 +++++
.../service/arrowflight/FlightSqlServiceImpl.java | 326 +++++++++++++++++++++
.../arrowflight/FlightStatementExecutor.java | 224 ++++++++++++++
.../main/java/org/apache/doris/system/Backend.java | 21 +-
.../org/apache/doris/system/BackendHbResponse.java | 11 +-
.../java/org/apache/doris/system/Frontend.java | 6 +
.../apache/doris/system/FrontendHbResponse.java | 11 +-
.../java/org/apache/doris/system/HeartbeatMgr.java | 12 +-
.../org/apache/doris/system/SystemInfoService.java | 1 +
.../tablefunction/BackendsTableValuedFunction.java | 1 +
.../FrontendsTableValuedFunction.java | 1 +
.../tablefunction/LocalTableValuedFunction.java | 2 +-
.../doris/tablefunction/MetadataGenerator.java | 1 +
.../org/apache/doris/system/HeartbeatMgrTest.java | 3 +
.../apache/doris/system/SystemInfoServiceTest.java | 2 +-
.../org/apache/doris/utframe/AnotherDemoTest.java | 4 +
.../doris/utframe/DemoMultiBackendsTest.java | 3 +-
.../apache/doris/utframe/MockedBackendFactory.java | 9 +-
.../org/apache/doris/utframe/MockedFrontend.java | 1 +
.../apache/doris/utframe/TestWithFeService.java | 6 +-
.../org/apache/doris/utframe/UtFrameUtils.java | 6 +-
fe/pom.xml | 73 ++++-
gensrc/proto/internal_service.proto | 11 +
gensrc/thrift/FrontendService.thrift | 1 +
gensrc/thrift/HeartbeatService.thrift | 1 +
.../data/performance_p0/redundant_conjuncts.out | 2 +
.../suites/demo_p0/httpTest_action.groovy | 2 +-
.../external_table_p0/tvf/test_backends_tvf.groovy | 2 +-
.../tvf/test_frontends_tvf.groovy | 4 +-
.../test_map_load_and_compaction.groovy | 2 +-
.../nereids_syntax_p0/information_schema.groovy | 2 +-
88 files changed, 1226 insertions(+), 71 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightSqlService.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightSqlServiceImpl.java
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/service/arrowflight/FlightStatementExecutor.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
