This is an automated email from the ASF dual-hosted git repository.
lokiore pushed a change to branch PHOENIX-7904-feature
in repository https://gitbox.apache.org/repos/asf/phoenix.git
from 87278a8865 PHOENIX-7906 :- Add UNKNOWN forward-compat sentinel for
TransformType (#2563)
add f9fc19fb85 PHOENIX-7933 Avoid using reflection to initialize
ServerCacheFactory (#2539)
add f4e88ed6f8 PHOENIX-7884 : Refactor tracking of IndexCdcConsumer lag
(#2506)
add 6442f2fbed PHOENIX-7883 : More metrics for EC index consumer (#2543)
add 08216f9c31 PHOENIX-7943 Add 2.6.0 to hbase.profile.list for release
(#2550)
add 7bc2f3fc34 PHOENIX-7944 maven-dependency-plugin analyze-only fails on
hbase-2.6.0 profile due to bouncycastle jdk15on/jdk18on mismatch (#2553)
add 132411c1d9 PHOENIX-7944 (addendum) Move bcprov-jdk18on unused-declared
ignore into phoenix-core pom (#2555)
add 182fd1cbe2 PHOENIX-7827 TableSnapshotReadsMapReduceIT per-test unique
snapshot name (#2444)
add 57573fa976 PHOENIX-7947 GlobalConnectionTenantTableIT NPE when
auto-unboxing (#2558)
add 5b10f02332 PHOENIX-7822 MaxConcurrentConnectionsIT poll for async
connection counts (#2439)
add d77ee927d8 PHOENIX-7825 ConcurrentMutationsIT make
MyClock.shouldAdvance volatile (#2442)
add 93941f5fd4 PHOENIX-7826 MetadataGetTableReadLockIT wait for
coprocessor swap to land (#2443)
add 0524930c78 PHOENIX-7830 De-flake MutableIndexFailureIT (#2447)
add 2d82a563ed PHOENIX-7831 PhoenixQueryTimeoutIT wait for
DelayedRegionObserver to load (#2448)
add 6f5e8a908c PHOENIX-7952 UpsertSelectIT is flaky due to a connection
leak check using a global counter (#2561)
add f2d7e8545b PHOENIX-7945 - Retain orphaned delete markers during
Phoenix compaction (#2562)
add 4e71d19232 PHOENIX-7839 MetaDataEndPointIT recategorize as
NeedsOwnMiniClusterTest (#2456)
add 1450981acd PHOENIX-7832 TenantViewOperationWorkloadIT add missing
break in WEIGHTED switch case (#2449)
add 2e28c72d75 PHOENIX-7823 AuditLoggingIT replace hardcoded table names
with generateUniqueName() (#2440)
add 081991a90d PHOENIX-7820 ConnectionQueryServicesImpl.createSnapshot
bounded retry on transient exception (#2438)
add f8c92e2d75 PHOENIX-7945 Fix OrphanDeleteMarkerCompactionIT timeout on
HBase 2.6 (addendum) (#2565)
add 80c9125514 PHOENIX-7953 Add addPhoenixDependencyJars utility for
MapReduce jobs (#2564)
add f5383027b3 PHOENIX-7855 Fix for flapper root cause:
java.lang.IllegalArgumentException: bound must be positive (#2475)
add e317e29024 PHOENIX-7833 CDCBaseIT/CDCQueryIT keep manual edge
installed after applyMutations (#2450)
add 4542a04175 PHOENIX-7834 CDCBaseIT do not force-delete a never-upserted
row (#2451)
add 948e033af5 PHOENIX-7840 UpdateCacheIT recategorize as
NeedsOwnMiniClusterTest (#2457)
add 5ebeb2a91d PHOENIX-7828 De-flake UCFWithDisabledIndexIT (#2445)
add 2358c6b5e9 PHOENIX-7824 ConcurrentMutationsExtendedIT fix wrong
TimeUnit on doneSignal.await (#2441)
add 1b55fb4b33 PHOENIX-7816 spotless addendum (#2578)
add e0289913b1 PHOENIX-7965 :- Guard
ConnectionQueryServicesImpl.getMetaDataCache() against a closed connection
(#2580)
add 77c478f1b0 PHOENIX-7969 Update supported client versions in backward
compatibility (#2584)
add 6d9ec471da PHOENIX-7980 Improve handling of test timeouts and resource
loss (#2593)
add 1c7e356f00 PHOENIX-7986 : Replace IndexCDCConsumer's exponential idle
backoff with a fixed poll interval (#2597)
add 05153be193 PHOENIX-7982 Data corruption in UPSERT SELECT with
VARBINARY_ENCODED (#2599)
add 032029746c PHOENIX-7961 Secondary index diverges from data table after
TTL expiry on partial-touch upserts (#2574)
add ff100f6a5d PHOENIX-8000 Conditional TTL not enforced at compaction for
SYSTEM tables (#2613)
add 631c72190e PHOENIX-8003 Reduce index mutation propagation gap for
eventually consistent GSIs (#2616)
add 96c05a47cb PHOENIX-7996 Correctly maintain immutable global indexes on
the server side for partial upserts (#2611)
new 4532937872 Merge remote-tracking branch 'upstream/master' into
PHOENIX-7904-feature-mm
The 1 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:
.../org/apache/phoenix/compile/DeleteCompiler.java | 19 +-
.../org/apache/phoenix/compile/UpsertCompiler.java | 21 +-
.../org/apache/phoenix/execute/MutationState.java | 8 +-
.../phoenix/expression/CoerceExpression.java | 36 +-
.../metrics/MetricsIndexCDCConsumerSource.java | 87 ++-
.../metrics/MetricsIndexCDCConsumerSourceImpl.java | 63 ++
.../org/apache/phoenix/index/IndexMaintainer.java | 8 +-
.../phoenix/index/IndexMetaDataCacheClient.java | 9 +-
.../org/apache/phoenix/jdbc/PhoenixConnection.java | 8 +-
.../phoenix/query/ConnectionQueryServicesImpl.java | 162 ++++-
.../org/apache/phoenix/schema/types/PBinary.java | 3 +
.../org/apache/phoenix/schema/types/PDataType.java | 6 +-
.../apache/phoenix/schema/types/PVarbinary.java | 5 +-
.../java/org/apache/phoenix/util/IndexUtil.java | 23 +-
.../java/org/apache/phoenix/util/ScanUtil.java | 99 +++
phoenix-core-server/pom.xml | 12 +
.../coprocessor/BaseScannerRegionObserver.java | 8 +
.../phoenix/coprocessor/CompactionScanner.java | 21 +-
.../coprocessor/ServerCachingEndpointImpl.java | 16 +-
.../apache/phoenix/coprocessor/ServerScanUtil.java | 123 ++++
.../phoenix/hbase/index/IndexCDCConsumer.java | 332 +++++----
.../hbase/index/IndexCDCConsumerProgress.java | 92 +++
.../phoenix/hbase/index/IndexRegionObserver.java | 227 +++++-
.../hbase/index/builder/BaseIndexBuilder.java | 5 -
.../hbase/index/builder/IndexBuildManager.java | 3 -
.../phoenix/hbase/index/builder/IndexBuilder.java | 7 -
.../apache/phoenix/index/PhoenixIndexBuilder.java | 6 -
.../phoenix/mapreduce/MultiHfileOutputFormat.java | 2 +
.../phoenix/mapreduce/PhoenixSyncTableTool.java | 1 +
.../phoenix/mapreduce/index/IndexScrutinyTool.java | 1 +
.../apache/phoenix/mapreduce/index/IndexTool.java | 1 +
.../phoenix/mapreduce/transform/TransformTool.java | 1 +
.../mapreduce/util/PhoenixMapReduceUtil.java | 61 ++
.../phoenix/schema/stats/UpdateStatisticsTool.java | 9 +-
phoenix-core/pom.xml | 9 +
.../org/apache/phoenix/end2end/AuditLoggingIT.java | 92 +--
.../end2end/BackwardCompatibilityTestUtil.java | 18 +-
.../java/org/apache/phoenix/end2end/Bson5IT.java | 2 -
.../java/org/apache/phoenix/end2end/CDCBaseIT.java | 27 +-
.../org/apache/phoenix/end2end/CDCQueryIT.java | 11 +-
.../phoenix/end2end/CDCStreamCompactionTTLIT.java | 153 ++++
...ncurrentMutationsCoveredEventualGenerateIT.java | 2 -
.../ConcurrentMutationsExtendedGenerateIT.java | 2 -
.../end2end/ConcurrentMutationsExtendedIT.java | 6 +-
.../phoenix/end2end/ConcurrentMutationsIT.java | 2 +-
.../ConcurrentMutationsLazyPostBatchWriteIT.java | 2 -
...urrentMutationsUncoveredEventualGenerateIT.java | 2 -
.../java/org/apache/phoenix/end2end/DeleteIT.java | 10 +-
.../phoenix/end2end/IndexCDCConsumerLagIT.java | 142 ++++
...xToolForNonTxGlobalIndexEventualGenerateIT.java | 2 -
.../IndexToolForNonTxGlobalIndexEventualIT.java | 2 -
.../org/apache/phoenix/end2end/IndexToolIT.java | 9 +-
.../apache/phoenix/end2end/MetaDataEndPointIT.java | 21 +-
.../end2end/MetadataGetTableReadLockIT.java | 20 +
.../MultiTenantEventualIndexGenerateIT.java | 2 -
.../end2end/MultiTenantEventualIndexIT.java | 2 -
.../end2end/OrphanDeleteMarkerCompactionIT.java | 432 ++++++++++++
.../end2end/TableSnapshotReadsMapReduceIT.java | 22 +-
.../phoenix/end2end/UCFWithDisabledIndexIT.java | 27 +-
.../org/apache/phoenix/end2end/UpsertSelectIT.java | 19 +-
.../phoenix/end2end/VarBinaryEncoded1IT.java | 290 +++++++-
.../phoenix/end2end/VarBinaryEncoded2IT.java | 2 -
.../VarBinaryEncodedIndexUpsertSelectIT.java | 138 ++++
.../VarBinaryEncodedServerUpsertSelectIT.java | 118 ++++
.../VarBinaryEncodedUpsertSelectTestUtil.java | 173 +++++
.../end2end/index/BaseImmutableIndexIT.java | 454 ++++++++++++
.../apache/phoenix/end2end/index/BaseIndexIT.java | 17 +-
.../end2end/index/BaseIndexWithRegionMovesIT.java | 14 +-
.../GlobalIndexCheckerEventualGenerateIT.java | 2 -
.../index/GlobalIndexCheckerEventualIT.java | 2 -
.../end2end/index/GlobalIndexCheckerIT.java | 71 ++
.../end2end/index/IndexDataTableSyncIT.java | 772 +++++++++++++++++++++
.../end2end/index/MutableIndexFailureIT.java | 5 +-
.../phoenix/iterate/PhoenixQueryTimeoutIT.java | 19 +
.../phoenix/monitoring/BasePhoenixMetricsIT.java | 2 +
.../monitoring/PhoenixTableLevelMetricsIT.java | 2 +
.../phoenix/query/MaxConcurrentConnectionsIT.java | 10 +-
.../org/apache/phoenix/rpc/PhoenixClientRpcIT.java | 9 +-
.../java/org/apache/phoenix/rpc/UpdateCacheIT.java | 19 +-
.../it/resources/compatible_client_versions.json | 181 +++--
.../hbase/index/IndexCDCConsumerProgressTest.java | 121 ++++
.../mapreduce/util/PhoenixMapReduceUtilTest.java | 50 ++
.../java/org/apache/phoenix/query/BaseTest.java | 23 +
.../query/ConnectionQueryServicesImplTest.java | 54 ++
.../apache/phoenix/schema/types/PDataTypeTest.java | 32 +
.../workload/mt/TenantViewOperationWorkloadIT.java | 1 +
pom.xml | 14 +-
87 files changed, 4686 insertions(+), 432 deletions(-)
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/coprocessor/ServerScanUtil.java
create mode 100644
phoenix-core-server/src/main/java/org/apache/phoenix/hbase/index/IndexCDCConsumerProgress.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/CDCStreamCompactionTTLIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/IndexCDCConsumerLagIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/OrphanDeleteMarkerCompactionIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/VarBinaryEncodedIndexUpsertSelectIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/VarBinaryEncodedServerUpsertSelectIT.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/VarBinaryEncodedUpsertSelectTestUtil.java
create mode 100644
phoenix-core/src/it/java/org/apache/phoenix/end2end/index/IndexDataTableSyncIT.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/hbase/index/IndexCDCConsumerProgressTest.java
create mode 100644
phoenix-core/src/test/java/org/apache/phoenix/mapreduce/util/PhoenixMapReduceUtilTest.java
