This is an automated email from the ASF dual-hosted git repository.
kishoreg pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from f48370c [TE] web - harleyjj/subscription-groups - add application
field to subscription group objects (#4938)
add 7bd5a7e Removing pinot-common dependency from pinot-hadoop-filesystem
and pin… (#4939)
No new revisions were added by this update.
Summary of changes:
pinot-azure-filesystem/pom.xml | 3 +-
.../org/apache/pinot/filesystem/AzurePinotFS.java | 15 ++-
.../apache/pinot/ingestion/common/PinotFSSpec.java | 4 +-
.../standalone/SegmentGenerationJobRunner.java | 2 +-
.../standalone/SegmentTarPushJobRunner.java | 8 +-
.../standalone/SegmentUriPushJobRunner.java | 8 +-
.../segmentCreationAndTarPushJobSpec.yaml | 2 +-
.../segmentCreationAndUriPushJobSpec.yaml | 2 +-
.../src/main/resources/segmentCreationJobSpec.yaml | 2 +-
.../src/main/resources/segmentTarPushJobSpec.yaml | 2 +-
.../src/main/resources/segmentUriPushJobSpec.yaml | 2 +-
.../common/segment/fetcher/HttpSegmentFetcher.java | 11 +-
.../segment/fetcher/PinotFSSegmentFetcher.java | 2 +-
.../apache/pinot/common/utils/CommonConstants.java | 20 ---
.../pinot/common/utils/helix/HelixHelper.java | 4 +-
.../apache/pinot/filesystem/LocalPinotFSTest.java | 1 +
.../pinot/filesystem/PinotFSFactoryTest.java | 18 ++-
.../impl/kafka/KafkaAvroMessageDecoder.java | 2 +-
.../apache/pinot/controller/ControllerConf.java | 2 +-
.../apache/pinot/controller/ControllerStarter.java | 2 +-
.../api/resources/ControllerFilePathProvider.java | 2 +-
.../resources/LLCSegmentCompletionHandlers.java | 2 +-
.../PinotSegmentUploadDownloadRestletResource.java | 2 +-
.../pinot/controller/api/upload/ZKOperator.java | 2 +-
.../helix/core/PinotHelixResourceManager.java | 4 +-
.../helix/core/PinotTableIdealStateBuilder.java | 2 +-
.../helix/core/SegmentDeletionManager.java | 2 +-
.../realtime/PinotLLCRealtimeSegmentManager.java | 4 +-
.../core/realtime/PinotRealtimeSegmentManager.java | 2 +-
.../api/ControllerFilePathProviderTest.java | 2 +-
.../pinot/controller/helix/HelixHelperTest.java | 2 +-
.../PinotLLCRealtimeSegmentManagerTest.java | 2 +-
.../core/util/SegmentDeletionManagerTest.java | 4 +-
pinot-hadoop-filesystem/pom.xml | 3 +-
.../org/apache/pinot/filesystem/HadoopPinotFS.java | 60 +++------
.../pinot/filesystem/HdfsSegmentFetcher.java | 135 -------------------
.../ControllerPeriodicTasksIntegrationTests.java | 2 +-
.../org/apache/pinot/minion/MinionStarter.java | 2 +-
.../minion/executor/SegmentConversionUtils.java | 4 +-
.../server/starter/helix/HelixServerStarter.java | 2 +-
.../starter/helix/SegmentFetcherAndLoader.java | 2 +-
.../helix/SegmentMessageHandlerFactory.java | 2 +-
.../apache/pinot/spi}/filesystem/LocalPinotFS.java | 14 +-
.../org/apache/pinot/spi/filesystem/PinotFS.java | 12 +-
.../pinot/spi/filesystem/PinotFSDelegator.java | 145 +++++++++++++++++++++
.../pinot/spi}/filesystem/PinotFSFactory.java | 8 +-
.../spi}/utils/retry/AttemptFailureException.java | 2 +-
.../utils/retry/AttemptsExceededException.java | 2 +-
.../pinot/spi}/utils/retry/BaseRetryPolicy.java | 2 +-
.../utils/retry/ExponentialBackoffRetryPolicy.java | 2 +-
.../spi}/utils/retry/FixedDelayRetryPolicy.java | 2 +-
.../pinot/spi}/utils/retry/NoDelayRetryPolicy.java | 2 +-
.../utils/retry/RetriableOperationException.java | 2 +-
.../pinot/spi}/utils/retry/RetryPolicies.java | 2 +-
.../apache/pinot/spi}/utils/retry/RetryPolicy.java | 2 +-
.../pinot/spi}/utils/retry/RetryPolicyTest.java | 9 +-
.../apache/pinot/tools/PinotIdealstateChanger.java | 2 +-
.../apache/pinot/tools/PinotNumReplicaChanger.java | 2 +-
.../tools/admin/command/MoveReplicaGroup.java | 2 +-
59 files changed, 287 insertions(+), 281 deletions(-)
delete mode 100644
pinot-hadoop-filesystem/src/main/java/org/apache/pinot/filesystem/HdfsSegmentFetcher.java
rename {pinot-common/src/main/java/org/apache/pinot =>
pinot-spi/src/main/java/org/apache/pinot/spi}/filesystem/LocalPinotFS.java (93%)
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/filesystem/PinotFSDelegator.java
rename {pinot-common/src/main/java/org/apache/pinot =>
pinot-spi/src/main/java/org/apache/pinot/spi}/filesystem/PinotFSFactory.java
(94%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/retry/AttemptFailureException.java
(96%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/retry/AttemptsExceededException.java
(96%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/retry/BaseRetryPolicy.java
(97%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/retry/ExponentialBackoffRetryPolicy.java
(97%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/retry/FixedDelayRetryPolicy.java
(96%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/retry/NoDelayRetryPolicy.java
(96%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/retry/RetriableOperationException.java
(96%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/retry/RetryPolicies.java
(97%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/retry/RetryPolicy.java (96%)
rename {pinot-common/src/test/java/org/apache/pinot/common =>
pinot-spi/src/test/java/org/apache/pinot/spi}/utils/retry/RetryPolicyTest.java
(85%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
