You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ja...@apache.org on 2019/10/21 17:22:31 UTC
[incubator-pinot] branch master updated (e9e6a33 -> a6f8f1e)
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/incubator-pinot.git.
from e9e6a33 [TE] frontend - harleyjj/alert-details - handle concurrency errors in alert details component (#4721)
add a6f8f1e [Resource Assignment] Plug in resource assignment to LLC REALTIME table (#4695)
No new revisions were added by this update.
Summary of changes:
.../PartitionAwareOfflineRoutingTableBuilder.java | 23 +-
...rtitionAwareOfflineRoutingTableBuilderTest.java | 44 +-
.../common/assignment/InstancePartitionsUtils.java | 32 +-
.../apache/pinot/common/config/IndexingConfig.java | 11 -
.../common/config/StreamConsumptionConfig.java | 35 -
.../apache/pinot/common/config/TableConfig.java | 10 -
.../apache/pinot/common/config/TagNameUtils.java | 15 -
.../pinot/common/metrics/ControllerMeter.java | 4 +-
.../common/partition/PartitionAssignment.java | 109 -
...roupBasedStreamPartitionAssignmentStrategy.java | 83 -
.../partition/ReplicaGroupPartitionAssignment.java | 124 --
.../ReplicaGroupPartitionAssignmentGenerator.java | 128 --
.../StreamPartitionAssignmentGenerator.java | 139 --
.../StreamPartitionAssignmentStrategy.java | 40 -
.../StreamPartitionAssignmentStrategyFactory.java | 45 -
.../UniformStreamPartitionAssignmentStrategy.java | 66 -
.../pinot/common/config/TableConfigTest.java | 23 -
.../common/partition/IdealStateBuilderUtil.java | 179 --
...icaGroupBasedStreamPartitionAssignmentTest.java | 136 --
.../StreamPartitionAssignmentGeneratorTest.java | 364 ----
.../UniformStreamPartitionAssignmentTest.java | 93 -
.../apache/pinot/controller/ControllerStarter.java | 2 +-
.../helix/core/PinotHelixResourceManager.java | 79 +-
.../helix/core/PinotTableIdealStateBuilder.java | 7 +-
.../instance/InstanceTagPoolSelector.java | 4 +-
.../assignment/segment/SegmentAssignmentUtils.java | 3 +-
.../realtime/PinotLLCRealtimeSegmentManager.java | 1395 +++++--------
.../core/realtime/SegmentCompletionManager.java | 63 +-
.../helix/core/realtime/TableConfigCache.java | 12 +-
.../segment/DefaultFlushThresholdUpdater.java | 46 +-
.../segment/FlushThresholdUpdateManager.java | 32 +-
.../realtime/segment/FlushThresholdUpdater.java | 22 +-
.../SegmentSizeBasedFlushThresholdUpdater.java | 45 +-
.../RealtimeSegmentValidationManager.java | 6 +-
.../PinotLLCRealtimeSegmentManagerTest.java | 2114 +++++++-------------
.../helix/core/realtime/SegmentCompletionTest.java | 32 +-
.../segment/FlushThresholdUpdaterTest.java | 939 +++------
.../ConsumingSegmentAssignmentStrategy.java | 61 -
.../segment/RealtimeSegmentAssignmentStrategy.java | 41 -
.../stream/PartitionLevelStreamConfig.java | 66 +-
.../pinot/core/realtime/stream/StreamConfig.java | 155 +-
.../impl/fakestream/FakeStreamConfigUtils.java | 10 -
.../ConsumingSegmentAssignmentStrategyTest.java | 285 ---
.../core/realtime/stream/StreamConfigTest.java | 242 +--
.../tests/PinotURIUploadIntegrationTest.java | 32 -
45 files changed, 1980 insertions(+), 5416 deletions(-)
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/config/StreamConsumptionConfig.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/partition/PartitionAssignment.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/partition/ReplicaGroupBasedStreamPartitionAssignmentStrategy.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/partition/ReplicaGroupPartitionAssignment.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/partition/ReplicaGroupPartitionAssignmentGenerator.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/partition/StreamPartitionAssignmentGenerator.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/partition/StreamPartitionAssignmentStrategy.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/partition/StreamPartitionAssignmentStrategyFactory.java
delete mode 100644 pinot-common/src/main/java/org/apache/pinot/common/partition/UniformStreamPartitionAssignmentStrategy.java
delete mode 100644 pinot-common/src/test/java/org/apache/pinot/common/partition/IdealStateBuilderUtil.java
delete mode 100644 pinot-common/src/test/java/org/apache/pinot/common/partition/ReplicaGroupBasedStreamPartitionAssignmentTest.java
delete mode 100644 pinot-common/src/test/java/org/apache/pinot/common/partition/StreamPartitionAssignmentGeneratorTest.java
delete mode 100644 pinot-common/src/test/java/org/apache/pinot/common/partition/UniformStreamPartitionAssignmentTest.java
delete mode 100644 pinot-core/src/main/java/org/apache/pinot/core/realtime/segment/ConsumingSegmentAssignmentStrategy.java
delete mode 100644 pinot-core/src/main/java/org/apache/pinot/core/realtime/segment/RealtimeSegmentAssignmentStrategy.java
delete mode 100644 pinot-core/src/test/java/org/apache/pinot/core/realtime/segment/ConsumingSegmentAssignmentStrategyTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org