This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 6fb7e521ef Add tracing for operator planning (#8523)
add ce0a08a49d Add connection based FailureDetector (#8491)
No new revisions were added by this update.
Summary of changes:
.../jmx_prometheus_javaagent/configs/broker.yml | 3 +
.../etc/jmx_prometheus_javaagent/configs/pinot.yml | 3 +
...BaseExponentialBackoffRetryFailureDetector.java | 190 +++++++++++++++++++++
.../failuredetector/ConnectionFailureDetector.java | 27 ++-
.../broker/failuredetector/FailureDetector.java | 105 ++++++++++++
.../failuredetector/FailureDetectorFactory.java | 73 ++++++++
.../failuredetector/NoOpFailureDetector.java | 55 +++---
.../requesthandler/GrpcBrokerRequestHandler.java | 1 +
.../SingleConnectionBrokerRequestHandler.java | 77 +++++++--
.../pinot/broker/routing/BrokerRoutingManager.java | 179 ++++++++++++++-----
.../routing/instanceselector/InstanceSelector.java | 2 +-
.../ConnectionFailureDetectorTest.java | 155 +++++++++++++++++
.../apache/pinot/common/metrics/BrokerGauge.java | 3 +-
.../spark/connector/PinotServerDataFetcher.scala | 2 +-
.../presto/PinotScatterGatherQueryClient.java | 5 +-
.../pinot/core/transport/AsyncQueryResponse.java | 71 +++++---
.../pinot/core/transport/DataTableHandler.java | 3 +-
.../apache/pinot/core/transport/QueryResponse.java | 76 +++++++++
.../apache/pinot/core/transport/QueryRouter.java | 24 ++-
.../pinot/core/transport/ServerChannels.java | 42 ++++-
.../pinot/core/transport/ServerInstance.java | 52 +++---
.../pinot/core/transport/ServerResponse.java | 2 +
.../core/transport/ServerRoutingInstance.java | 37 ++--
.../query/reduce/StreamingReduceServiceTest.java | 6 +-
.../pinot/core/transport/QueryRoutingTest.java | 14 +-
.../MultiNodesOfflineClusterIntegrationTest.java | 63 +++++++
.../pinot/server/starter/ServerInstance.java | 11 +-
.../apache/pinot/spi/utils/CommonConstants.java | 35 +++-
28 files changed, 1114 insertions(+), 202 deletions(-)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/failuredetector/BaseExponentialBackoffRetryFailureDetector.java
copy
pinot-core/src/main/java/org/apache/pinot/core/query/reduce/StreamingReducer.java
=>
pinot-broker/src/main/java/org/apache/pinot/broker/failuredetector/ConnectionFailureDetector.java
(52%)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/failuredetector/FailureDetector.java
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/failuredetector/FailureDetectorFactory.java
copy
pinot-core/src/main/java/org/apache/pinot/core/query/utils/idset/EmptyIdSet.java
=>
pinot-broker/src/main/java/org/apache/pinot/broker/failuredetector/NoOpFailureDetector.java
(51%)
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/failuredetector/ConnectionFailureDetectorTest.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/transport/QueryResponse.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
