This is an automated email from the ASF dual-hosted git repository.
morningman pushed a change to branch dev-1.0.1
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
from 8928954865 [fix](ut)(compile) Fix ut failure at functions_geo and
compilation bug (#8843)
new 7b989c0c97 Window funnel (#8485)
new b77baafcac min and max window function bug fix (#8822)
new 7aace71325 [improvement](hll) Optimize Hyperloglog (#8829)
new 28892f2807 [fix](storage) Fix core bug of convert to predicate column
(#8833)
new 1eebb658e1 [fix](ut) fix fe run CreateTableAsSelectStmtTest
,UserPropertyTest, ProjectPlannerFunctionTest and AggregateTest failed (#8838)
new cf94d9fe0f [feature](diagnose) support "ADMIN DIAGNOSE TABLET" stmt
(#8839)
new e882eecbee [Refactor][httpv2]remove http v1 code (#8848)
new 5b6f9329c8 [Fix](Lateral View) The Error expr type when exploding a
function result of inline view (#8851)
new 8c4c4b237f [improvement](restore) set table property
'dynamic_partition.enable' to false after restore (#8852)
new 930b458901 [fix] access parallel_flat_hash_map via thread safely
methods (#8854)
new b86f290a7c [fix] Disable cast operation of object type (#8882)
new 32ccf29b86 [feature](vectorized) support vexplode_bitmap (#8890)
new f7ee301995 [fix](datax) Fix the problem of keyword error when
importing datax (#8893)
new 075f9e6420 [fix](ut)(memory-leak) Fix be asan ut failed and hdfs file
reader memory leak (#8905)
The 14 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/exec/hdfs_file_reader.cpp | 1 +
be/src/exprs/agg_fn_evaluator.cpp | 2 +-
be/src/exprs/aggregate_functions.cpp | 213 +++++++++-
be/src/exprs/aggregate_functions.h | 10 +
be/src/exprs/table_function/explode_bitmap.h | 5 +-
.../table_function/table_function_factory.cpp | 13 +-
be/src/olap/hll.cpp | 143 ++-----
be/src/olap/hll.h | 118 ++----
be/src/olap/rowset/segment_v2/binary_dict_page.cpp | 2 +-
be/src/util/brpc_client_cache.h | 17 +-
be/src/vec/CMakeLists.txt | 2 +
.../aggregate_function_simple_factory.cpp | 5 +-
...ader.h => aggregate_function_window_funnel.cpp} | 24 +-
.../aggregate_function_window_funnel.h | 214 ++++++++++
be/src/vec/columns/column.h | 2 +-
be/src/vec/columns/column_dictionary.h | 14 +-
be/src/vec/columns/column_nullable.h | 6 +-
.../{vexplode_numbers.cpp => vexplode_bitmap.cpp} | 54 ++-
.../{vexplode_numbers.h => vexplode_bitmap.h} | 17 +-
be/src/vec/functions/function_fake.cpp | 1 +
be/src/vec/functions/function_fake.h | 8 +
be/test/exprs/CMakeLists.txt | 2 +-
be/test/exprs/window_funnel_test.cpp | 431 +++++++++++++++++++++
be/test/vec/aggregate_functions/CMakeLists.txt | 1 +
.../aggregate_functions/vec_window_funnel_test.cpp | 425 ++++++++++++++++++++
docs/.vuepress/sidebar/en.js | 1 +
docs/.vuepress/sidebar/zh-CN.js | 1 +
.../Administration/ADMIN-DIAGNOSE-TABLET.md | 59 +++
.../Administration/ADMIN-DIAGNOSE-TABLET.md | 59 +++
.../writer/doriswriter/DorisWriterEmitter.java | 3 +-
fe/fe-core/pom.xml | 4 +-
fe/fe-core/src/main/cup/sql_parser.cup | 8 +-
.../src/main/java/org/apache/doris/PaloFe.java | 29 +-
...tionsStmt.java => AdminDiagnoseTabletStmt.java} | 51 ++-
.../java/org/apache/doris/analysis/Analyzer.java | 1 -
.../java/org/apache/doris/analysis/CastExpr.java | 28 +-
.../apache/doris/analysis/FunctionCallExpr.java | 72 +++-
.../org/apache/doris/analysis/LateralViewRef.java | 12 +-
.../java/org/apache/doris/backup/RestoreJob.java | 3 +
.../apache/doris/catalog/AggregateFunction.java | 2 +-
.../java/org/apache/doris/catalog/Catalog.java | 5 +-
.../main/java/org/apache/doris/catalog/Column.java | 5 +-
.../java/org/apache/doris/catalog/FunctionSet.java | 31 ++
.../java/org/apache/doris/catalog/OlapTable.java | 10 +
.../org/apache/doris/catalog/PrimitiveType.java | 8 -
.../java/org/apache/doris/catalog/ScalarType.java | 12 +-
.../org/apache/doris/catalog/TableProperty.java | 12 +
.../main/java/org/apache/doris/catalog/Type.java | 4 +
.../main/java/org/apache/doris/common/Config.java | 17 -
.../org/apache/doris/http/ActionController.java | 88 -----
.../java/org/apache/doris/http/BaseAction.java | 375 ------------------
.../java/org/apache/doris/http/BaseRequest.java | 158 --------
.../java/org/apache/doris/http/BaseResponse.java | 99 -----
.../org/apache/doris/http/HttpAuthManager.java | 64 ---
.../java/org/apache/doris/http/HttpServer.java | 279 -------------
.../org/apache/doris/http/HttpServerHandler.java | 117 ------
.../main/java/org/apache/doris/http/IAction.java | 25 --
.../apache/doris/http/UnauthorizedException.java | 26 --
.../main/java/org/apache/doris/http/WebUtils.java | 230 -----------
.../apache/doris/http/action/BackendAction.java | 101 -----
.../org/apache/doris/http/action/HaAction.java | 174 ---------
.../org/apache/doris/http/action/HelpAction.java | 223 -----------
.../org/apache/doris/http/action/IndexAction.java | 275 -------------
.../org/apache/doris/http/action/LogAction.java | 168 --------
.../apache/doris/http/action/NotFoundAction.java | 52 ---
.../org/apache/doris/http/action/QueryAction.java | 127 ------
.../doris/http/action/QueryProfileAction.java | 68 ----
.../apache/doris/http/action/SessionAction.java | 85 ----
.../doris/http/action/StaticResourceAction.java | 242 ------------
.../org/apache/doris/http/action/SystemAction.java | 184 ---------
.../apache/doris/http/action/VariableAction.java | 84 ----
.../apache/doris/http/action/WebBaseAction.java | 374 ------------------
.../http/common/DorisHttpPostObjectAggregator.java | 61 ---
.../doris/http/meta/ColocateMetaService.java | 229 -----------
.../doris/http/meta/InvalidClientException.java | 26 --
.../org/apache/doris/http/meta/MetaBaseAction.java | 108 ------
.../org/apache/doris/http/meta/MetaService.java | 356 -----------------
.../doris/http/rest/BootstrapFinishAction.java | 162 --------
.../apache/doris/http/rest/CancelStreamLoad.java | 83 ----
.../doris/http/rest/CheckDecommissionAction.java | 93 -----
.../apache/doris/http/rest/ConnectionAction.java | 62 ---
.../apache/doris/http/rest/GetDdlStmtAction.java | 108 ------
.../apache/doris/http/rest/GetLoadInfoAction.java | 88 -----
.../apache/doris/http/rest/GetLogFileAction.java | 131 -------
.../apache/doris/http/rest/GetSmallFileAction.java | 92 -----
.../apache/doris/http/rest/GetStreamLoadState.java | 86 ----
.../org/apache/doris/http/rest/HealthAction.java | 47 ---
.../org/apache/doris/http/rest/LoadAction.java | 141 -------
.../doris/http/rest/MetaReplayerCheckAction.java | 70 ----
.../org/apache/doris/http/rest/MetricsAction.java | 65 ----
.../apache/doris/http/rest/MigrationAction.java | 164 --------
.../org/apache/doris/http/rest/MultiAbort.java | 72 ----
.../org/apache/doris/http/rest/MultiCommit.java | 77 ----
.../java/org/apache/doris/http/rest/MultiDesc.java | 85 ----
.../java/org/apache/doris/http/rest/MultiList.java | 82 ----
.../org/apache/doris/http/rest/MultiStart.java | 92 -----
.../org/apache/doris/http/rest/MultiUnload.java | 76 ----
.../org/apache/doris/http/rest/ProfileAction.java | 60 ---
.../apache/doris/http/rest/QueryDetailAction.java | 56 ---
.../org/apache/doris/http/rest/RestBaseAction.java | 127 ------
.../org/apache/doris/http/rest/RowCountAction.java | 115 ------
.../apache/doris/http/rest/SetConfigAction.java | 136 -------
.../org/apache/doris/http/rest/ShowDataAction.java | 91 -----
.../apache/doris/http/rest/ShowMetaInfoAction.java | 203 ----------
.../org/apache/doris/http/rest/ShowProcAction.java | 136 -------
.../doris/http/rest/ShowRuntimeInfoAction.java | 69 ----
.../doris/http/rest/StorageTypeCheckAction.java | 98 -----
.../doris/http/rest/TableQueryPlanAction.java | 306 ---------------
.../doris/http/rest/TableRowCountAction.java | 113 ------
.../apache/doris/http/rest/TableSchemaAction.java | 135 -------
.../{http => httpv2}/IllegalArgException.java | 25 +-
.../{http/rest => httpv2/entity}/ActionStatus.java | 2 +-
.../rest => httpv2/entity}/RestBaseResult.java | 4 +-
.../{http/rest => httpv2/entity}/RestResult.java | 5 +-
.../doris/httpv2/rest/GetLoadInfoAction.java | 2 +-
.../org/apache/doris/httpv2/rest/LoadAction.java | 2 +-
.../org/apache/doris/httpv2/rest/MultiAction.java | 2 +-
.../apache/doris/journal/bdbje/BDBDebugger.java | 22 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 11 +
.../java/org/apache/doris/system/Diagnoser.java | 163 ++++++++
fe/fe-core/src/main/jflex/sql_scanner.flex | 1 +
.../org/apache/doris/analysis/AggregateTest.java | 93 ++++-
.../analysis/CreateTableAsSelectStmtTest.java | 25 +-
.../org/apache/doris/catalog/OlapTableTest.java | 42 ++
.../org/apache/doris/catalog/UserPropertyTest.java | 41 ++
.../doris/clone/TabletReplicaTooSlowTest.java | 8 +
.../org/apache/doris/common/path/PathTrieTest.java | 19 -
.../org/apache/doris/http/DorisHttpTestCase.java | 23 +-
.../org/apache/doris/http/HttpAuthManagerTest.java | 18 +-
.../doris/planner/ProjectPlannerFunctionTest.java | 2 +-
.../org/apache/doris/planner/QueryPlanTest.java | 31 +-
.../doris/planner/TableFunctionPlanTest.java | 23 +-
132 files changed, 2238 insertions(+), 8412 deletions(-)
copy be/src/vec/aggregate_functions/{aggregate_function_reader.h =>
aggregate_function_window_funnel.cpp} (53%)
create mode 100644
be/src/vec/aggregate_functions/aggregate_function_window_funnel.h
copy be/src/vec/exprs/table_function/{vexplode_numbers.cpp =>
vexplode_bitmap.cpp} (61%)
copy be/src/vec/exprs/table_function/{vexplode_numbers.h => vexplode_bitmap.h}
(68%)
create mode 100644 be/test/exprs/window_funnel_test.cpp
create mode 100644 be/test/vec/aggregate_functions/vec_window_funnel_test.cpp
create mode 100644
docs/en/sql-reference/sql-statements/Administration/ADMIN-DIAGNOSE-TABLET.md
create mode 100644
docs/zh-CN/sql-reference/sql-statements/Administration/ADMIN-DIAGNOSE-TABLET.md
copy
fe/fe-core/src/main/java/org/apache/doris/analysis/{ShowMigrationsStmt.java =>
AdminDiagnoseTabletStmt.java} (69%)
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/ActionController.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/BaseAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/BaseRequest.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/BaseResponse.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/HttpAuthManager.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/HttpServer.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/HttpServerHandler.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/http/IAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/UnauthorizedException.java
delete mode 100644 fe/fe-core/src/main/java/org/apache/doris/http/WebUtils.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/BackendAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/HaAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/HelpAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/IndexAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/LogAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/NotFoundAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/QueryAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/QueryProfileAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/SessionAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/StaticResourceAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/SystemAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/VariableAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/action/WebBaseAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/common/DorisHttpPostObjectAggregator.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/meta/ColocateMetaService.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/meta/InvalidClientException.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/meta/MetaBaseAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/meta/MetaService.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/BootstrapFinishAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/CancelStreamLoad.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/CheckDecommissionAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/ConnectionAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/GetDdlStmtAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/GetLoadInfoAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/GetLogFileAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/GetSmallFileAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/GetStreamLoadState.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/HealthAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/LoadAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/MetaReplayerCheckAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/MetricsAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/MigrationAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/MultiAbort.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/MultiCommit.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/MultiDesc.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/MultiList.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/MultiStart.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/MultiUnload.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/ProfileAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/QueryDetailAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/RestBaseAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/RowCountAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/SetConfigAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/ShowDataAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/ShowMetaInfoAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/ShowProcAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/ShowRuntimeInfoAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/StorageTypeCheckAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/TableQueryPlanAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/TableRowCountAction.java
delete mode 100644
fe/fe-core/src/main/java/org/apache/doris/http/rest/TableSchemaAction.java
rename fe/fe-core/src/main/java/org/apache/doris/{http =>
httpv2}/IllegalArgException.java (72%)
rename fe/fe-core/src/main/java/org/apache/doris/{http/rest =>
httpv2/entity}/ActionStatus.java (95%)
rename fe/fe-core/src/main/java/org/apache/doris/{http/rest =>
httpv2/entity}/RestBaseResult.java (97%)
rename fe/fe-core/src/main/java/org/apache/doris/{http/rest =>
httpv2/entity}/RestResult.java (94%)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/system/Diagnoser.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
