This is an automated email from the ASF dual-hosted git repository.
xiangfu0 pushed a change to branch xiangfu0/agg-rewrite/04-any-value
in repository https://gitbox.apache.org/repos/asf/pinot.git
from e1278625f0e Default the ANY_VALUE data type inference to off
add 083f2937380 Meter failed ERROR-segment repairs per table (#20018)
add e3b4e41cb29 Track partition assignment in IdealState for strict
replica-group tables (#19916)
add 62958d8ff1b Throw FileNotFoundException from
GcsPinotFS.copyToLocalFile for a missing object (#20026)
add aea5680a40b Detect servers that stop answering queries but keep their
connection open (#19452)
add c5ac29be0e6 Refresh MSE gRPC channels when a server restarts (#19875)
add ad6b54f7b38 Enable query fingerprinting by default and reload cluster
overrides (#20038)
add 5cf721fe14d Merge remote-tracking branch 'origin/master' into
xiangfu0/agg-rewrite/04-any-value
No new revisions were added by this update.
Summary of changes:
.../broker/broker/helix/BaseBrokerStarter.java | 11 +-
.../requesthandler/BaseBrokerRequestHandler.java | 39 +-
.../BaseSingleStageBrokerRequestHandler.java | 21 +-
.../MultiStageBrokerRequestHandler.java | 22 +-
.../SingleConnectionBrokerRequestHandler.java | 73 +-
.../routing/manager/BaseBrokerRoutingManager.java | 23 +-
.../BaseSingleStageBrokerRequestHandlerTest.java | 94 ++-
.../MultiStageBrokerRequestHandlerTest.java | 77 ++
...ionBrokerRequestHandlerFailureDetectorTest.java | 450 +++++++++++
.../routing/manager/BrokerRoutingManagerTest.java | 33 +-
.../assignment/PartitionAssignmentUtils.java | 117 +++
...BaseExponentialBackoffRetryFailureDetector.java | 132 +++-
.../failuredetector/ConnectionFailureDetector.java | 9 +-
.../common/failuredetector/FailureDetector.java | 23 +
.../pinot/common/metadata/ZKMetadataProvider.java | 10 +-
.../pinot/common/metrics/ControllerMeter.java | 6 +-
.../pinot/common/request/InstanceRequest.java | 106 ++-
.../assignment/PartitionAssignmentUtilsTest.java | 65 ++
.../ConnectionFailureDetectorTest.java | 284 ++++++-
pinot-common/src/thrift/request.thrift | 4 +
.../helix/core/PinotHelixResourceManager.java | 34 +-
.../assignment/segment/BaseSegmentAssignment.java | 174 +++-
.../BaseStrictRealtimeSegmentAssignment.java | 146 ----
.../MultiTierStrictRealtimeSegmentAssignment.java | 131 ---
.../segment/OfflineSegmentAssignment.java | 136 +++-
.../segment/RealtimeSegmentAssignment.java | 193 ++++-
.../core/assignment/segment/SegmentAssignment.java | 18 +-
.../segment/SegmentAssignmentFactory.java | 26 +-
.../assignment/segment/SegmentAssignmentUtils.java | 11 +
.../SingleTierStrictRealtimeSegmentAssignment.java | 75 --
.../core/assignment/segment/TableAssignment.java | 59 ++
.../core/cleanup/StaleInstancesCleanupTask.java | 9 +-
.../realtime/PinotLLCRealtimeSegmentManager.java | 53 +-
.../helix/core/rebalance/TableRebalancer.java | 876 ++++++++++++---------
.../PinotHelixResourceManagerStatelessTest.java | 17 +
...NonReplicaGroupTieredSegmentAssignmentTest.java | 49 +-
...artitionPinnedOfflineSegmentAssignmentTest.java | 353 +++++++++
...rtitionPinnedRealtimeSegmentAssignmentTest.java | 704 +++++++++++++++++
...altimeNonReplicaGroupSegmentAssignmentTest.java | 82 +-
...NonReplicaGroupTieredSegmentAssignmentTest.java | 42 +-
.../RealtimeReplicaGroupSegmentAssignmentTest.java | 158 ++--
.../segment/SegmentAssignmentTestUtils.java | 10 +
.../StrictRealtimeSegmentAssignmentTest.java | 527 -------------
.../AllServersSegmentAssignmentStrategyTest.java | 37 +-
.../BalancedNumSegmentAssignmentStrategyTest.java | 40 +-
.../ReplicaGroupSegmentAssignmentStrategyTest.java | 148 ++--
...nReplicaGroupSegmentAssignmentStrategyTest.java | 43 +-
.../RoundRobinSegmentAssignmentStrategyTest.java | 28 +-
.../cleanup/StaleInstancesCleanupTaskTest.java | 29 +
.../PinotLLCRealtimeSegmentManagerTest.java | 44 +-
.../TableRebalancerClusterStatelessTest.java | 43 +
.../helix/core/rebalance/TableRebalancerTest.java | 339 ++++++--
.../core/transport/InstanceRequestHandler.java | 19 +
.../apache/pinot/core/transport/QueryRouter.java | 149 +++-
.../pinot/core/transport/ServerChannels.java | 47 +-
.../core/transport/InstanceRequestHandlerTest.java | 56 ++
.../pinot/core/transport/QueryRoutingTest.java | 270 +++++++
.../pinot/core/transport/QueryServerTestUtils.java | 69 ++
.../pinot/core/transport/ServerChannelsTest.java | 39 +-
.../apache/pinot/plugin/filesystem/GcsPinotFS.java | 4 +-
.../filesystem/GcsPinotFSNullSafetyTest.java | 22 +
.../apache/pinot/query/mailbox/MailboxService.java | 18 +-
.../query/mailbox/channel/ChannelManager.java | 73 +-
.../query/service/dispatch/DispatchClient.java | 21 +
.../query/service/dispatch/QueryDispatcher.java | 36 +-
.../query/mailbox/channel/ChannelManagerTest.java | 111 ++-
.../service/dispatch/QueryDispatcherTest.java | 83 ++
.../server/starter/helix/BaseServerStarter.java | 10 +-
...ava => ServerMailboxChannelRefreshHandler.java} | 107 ++-
...=> ServerMailboxChannelRefreshHandlerTest.java} | 155 +++-
.../apache/pinot/spi/utils/CommonConstants.java | 25 +-
71 files changed, 5552 insertions(+), 1995 deletions(-)
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/requesthandler/SingleConnectionBrokerRequestHandlerFailureDetectorTest.java
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/assignment/PartitionAssignmentUtils.java
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/assignment/PartitionAssignmentUtilsTest.java
delete mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/BaseStrictRealtimeSegmentAssignment.java
delete mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/MultiTierStrictRealtimeSegmentAssignment.java
delete mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/SingleTierStrictRealtimeSegmentAssignment.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/TableAssignment.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/PartitionPinnedOfflineSegmentAssignmentTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/PartitionPinnedRealtimeSegmentAssignmentTest.java
delete mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/StrictRealtimeSegmentAssignmentTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/transport/QueryServerTestUtils.java
rename
pinot-server/src/main/java/org/apache/pinot/server/starter/helix/{ServerGrpcChannelBackoffResetHandler.java
=> ServerMailboxChannelRefreshHandler.java} (53%)
rename
pinot-server/src/test/java/org/apache/pinot/server/starter/helix/{ServerGrpcChannelBackoffResetHandlerTest.java
=> ServerMailboxChannelRefreshHandlerTest.java} (55%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
