This is an automated email from the ASF dual-hosted git repository.
stigahuang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/impala.git
from 35c6a0b76 IMPALA-13726 Add admission control slots to /queries page in
webui
new d5f43ff19 IMPALA-13523: Decimal precision and scale needs to be in
return type
new 6fbde7296 IMPALA-13694: Add ImpalaTestSuite.__reset_impala_clients
method
new 9c5ed44d5 IMPALA-13739: Part1: Move FileDescriptor, FileBlock and
BlockReplica
new c729b13a1 IMPALA-13345: Log the package/class name when changing FE
log levels
The 4 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/util/logging-support.cc | 2 +-
.../apache/impala/analysis/ComputeStatsStmt.java | 2 +-
.../org/apache/impala/analysis/OptimizeStmt.java | 9 +-
.../java/org/apache/impala/analysis/TableRef.java | 8 +-
.../org/apache/impala/catalog/BlockReplica.java | 59 +++
.../apache/impala/catalog/CatalogHmsAPIHelper.java | 1 -
.../impala/catalog/CatalogServiceCatalog.java | 1 -
.../org/apache/impala/catalog/FeCatalogUtils.java | 1 -
.../org/apache/impala/catalog/FeFsPartition.java | 1 -
.../java/org/apache/impala/catalog/FeFsTable.java | 1 -
.../org/apache/impala/catalog/FeIcebergTable.java | 10 +-
.../java/org/apache/impala/catalog/FileBlock.java | 215 +++++++++
.../org/apache/impala/catalog/FileDescriptor.java | 367 ++++++++++++++
.../apache/impala/catalog/FileMetadataLoader.java | 1 -
.../org/apache/impala/catalog/HdfsPartition.java | 531 +--------------------
.../java/org/apache/impala/catalog/HdfsTable.java | 4 +-
.../impala/catalog/IcebergContentFileStore.java | 1 -
.../apache/impala/catalog/IcebergDeleteTable.java | 1 -
.../impala/catalog/IcebergEqualityDeleteTable.java | 1 -
.../impala/catalog/IcebergFileMetadataLoader.java | 3 -
.../impala/catalog/IcebergPositionDeleteTable.java | 1 -
.../impala/catalog/ParallelFileMetadataLoader.java | 1 -
.../impala/catalog/local/CatalogdMetaProvider.java | 2 +-
.../impala/catalog/local/DirectMetaProvider.java | 2 +-
.../impala/catalog/local/LocalFsPartition.java | 2 +-
.../apache/impala/catalog/local/LocalFsTable.java | 2 +-
.../apache/impala/catalog/local/MetaProvider.java | 2 +-
.../catalog/metastore/CatalogHmsClientUtils.java | 2 +-
.../org/apache/impala/planner/HdfsScanNode.java | 4 +-
.../org/apache/impala/planner/IcebergScanNode.java | 2 +-
.../apache/impala/planner/IcebergScanPlanner.java | 2 +-
.../java/org/apache/impala/util/AcidUtils.java | 2 +-
.../impala/catalog/FileMetadataLoaderTest.java | 1 -
.../apache/impala/catalog/HdfsPartitionTest.java | 1 -
.../catalog/IcebergContentFileStoreTest.java | 1 -
.../catalog/PartialCatalogInfoWriteIdTest.java | 4 +-
.../events/MetastoreEventsProcessorTest.java | 9 +-
.../catalog/local/CatalogdMetaProviderTest.java | 3 +-
.../impala/catalog/local/LocalCatalogTest.java | 2 +-
.../metastore/CatalogHmsFileMetadataTest.java | 4 +-
.../metastore/EnableCatalogdHmsCacheFlagTest.java | 2 +-
.../org/apache/impala/planner/ExplainTest.java | 5 +-
.../apache/impala/testutil/BlockIdGenerator.java | 2 +-
.../calcite/coercenodes/CoerceOperandShuttle.java | 87 ++--
.../calcite/operators/CommonOperatorFunctions.java | 7 +-
.../queries/QueryTest/decimal-exprs.test | 18 +
.../functional-query/queries/QueryTest/exprs.test | 11 +
tests/authorization/test_authorization.py | 7 +-
tests/beeswax/impala_beeswax.py | 4 +-
tests/common/impala_connection.py | 46 +-
tests/common/impala_test_suite.py | 58 ++-
tests/common/test_vector.py | 8 +-
tests/custom_cluster/test_admission_controller.py | 6 +-
tests/custom_cluster/test_hs2_fault_injection.py | 6 +-
tests/custom_cluster/test_kudu.py | 3 +
tests/custom_cluster/test_mt_dop.py | 7 +-
.../test_runtime_filter_aggregation.py | 3 +
tests/hs2/hs2_test_suite.py | 6 +
tests/query_test/test_exprs.py | 102 ++--
tests/query_test/test_hdfs_caching.py | 88 ++--
tests/query_test/test_iceberg.py | 6 +
tests/query_test/test_insert_behaviour.py | 10 +-
tests/query_test/test_kudu.py | 3 +
tests/query_test/test_runtime_filters.py | 3 +
64 files changed, 1026 insertions(+), 740 deletions(-)
create mode 100644 fe/src/main/java/org/apache/impala/catalog/BlockReplica.java
create mode 100644 fe/src/main/java/org/apache/impala/catalog/FileBlock.java
create mode 100644
fe/src/main/java/org/apache/impala/catalog/FileDescriptor.java
