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 42335ae68d Improve error message when colocated join is requested but
workermanager is disabled (#14947)
add 7fcb82cc00 Pauseless Consumption #3: Disaster Recovery with
Reingestion (#14920)
No new revisions were added by this update.
Summary of changes:
.../pinot/common/metrics/ControllerGauge.java | 5 +-
.../common/utils/FileUploadDownloadClient.java | 7 +
.../PinotSegmentUploadDownloadRestletResource.java | 121 ++++++
.../pinot/controller/api/upload/ZKOperator.java | 39 ++
.../realtime/PinotLLCRealtimeSegmentManager.java | 176 ++++++++
.../RealtimeSegmentValidationManager.java | 13 +-
.../realtime/RealtimeSegmentDataManager.java | 2 +-
.../manager/realtime/RealtimeTableDataManager.java | 16 +-
.../ServerSegmentCompletionProtocolHandler.java | 110 ++++-
.../tests/BasePauselessRealtimeIngestionTest.java | 46 +-
...sRealtimeIngestionSegmentCommitFailureTest.java | 308 ++++++++++++++
...ureInjectingPinotLLCRealtimeSegmentManager.java | 23 +
...FailureInjectingRealtimeSegmentDataManager.java | 66 +++
.../FailureInjectingRealtimeTableDataManager.java | 69 +++
.../FailureInjectingTableDataManagerProvider.java | 13 +-
.../writer/StatelessRealtimeSegmentWriter.java | 464 +++++++++++++++++++++
.../server/api/resources/ReingestionResource.java | 278 ++++++++++++
17 files changed, 1702 insertions(+), 54 deletions(-)
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/PauselessRealtimeIngestionSegmentCommitFailureTest.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/realtime/utils/FailureInjectingRealtimeSegmentDataManager.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/realtime/utils/FailureInjectingRealtimeTableDataManager.java
copy
pinot-core/src/main/java/org/apache/pinot/core/data/manager/provider/DefaultTableDataManagerProvider.java
=>
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/realtime/utils/FailureInjectingTableDataManagerProvider.java
(89%)
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/realtime/writer/StatelessRealtimeSegmentWriter.java
create mode 100644
pinot-server/src/main/java/org/apache/pinot/server/api/resources/ReingestionResource.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]