This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch standalone-pbnj
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
discard e77b42e Rebase and address comments
discard 0711c1c Merge branch 'standalone-pbnj' of
github.com:apache/incubator-pinot into standalone-pbnj
discard 0d9f64d Address comments
discard 63e10fe rename pinot-ingestion-jobs module to pinot-batch-ingestion
discard 242eb1d update comments 1
discard 59905e6 Adding segment push jobs
discard d051ead Make whole pipeline works
discard a01d930 Adding pinot-standalone module to generate segments
discard 3c72e6c Address comments
discard a26929d rename pinot-ingestion-jobs module to pinot-batch-ingestion
discard 37c6470 update comments 1
discard 552073e Adding segment push jobs
discard 40cfba3 Make whole pipeline works
discard f436245 Adding pinot-standalone module to generate segments
add a93f129 Simplifying interface related to StreamLevelConsumer (#4883)
add 79407b5 Failure to recover after segment reload failure does not
release segment lock (#4882)
add 69340a6 Adding pinot-standalone module to generate segments
add 33ae834 Make whole pipeline works
add a4e8985 Adding segment push jobs
add 3446a42 update comments 1
add 32125ef rename pinot-ingestion-jobs module to pinot-batch-ingestion
add 4be6233 Address comments
add b3c47ca Adding pinot-standalone module to generate segments
add e7aa57c Make whole pipeline works
add 4772747 Adding segment push jobs
add d57f093 update comments 1
add a15f467 rename pinot-ingestion-jobs module to pinot-batch-ingestion
add fd4267b Rebase and address comments
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (e77b42e)
\
N -- N -- N refs/heads/standalone-pbnj (fd4267b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../segmentCreationAndTarPushJobSpec.yaml | 2 +-
.../src/main/resources/segmentTarPushJobSpec.yaml | 2 +-
.../realtime/impl/kafka/KafkaConsumerFactory.java | 9 +++-----
.../impl/kafka/KafkaHighLevelStreamConfig.java | 7 +++---
.../impl/kafka/KafkaStreamLevelConsumer.java | 27 ++++------------------
.../realtime/impl/kafka2/KafkaConsumerFactory.java | 6 ++---
.../impl/kafka2/KafkaStreamLevelConsumer.java | 22 +++---------------
.../impl/kafka2/KafkaStreamLevelStreamConfig.java | 7 +++---
.../realtime/HLRealtimeSegmentDataManager.java | 15 +++++++++++-
.../realtime/LLRealtimeSegmentDataManager.java | 2 +-
.../core/indexsegment/mutable/MutableSegment.java | 2 +-
.../indexsegment/mutable/MutableSegmentImpl.java | 2 +-
.../pinot/core/realtime/stream/MessageBatch.java | 1 -
.../pinot/core/realtime/stream}/RowMetadata.java | 2 +-
.../realtime/stream/StreamConsumerFactory.java | 5 ++--
.../realtime/stream/StreamMessageMetadata.java | 3 ---
.../impl/fakestream/FakeStreamConsumerFactory.java | 2 +-
...lakyConsumerRealtimeClusterIntegrationTest.java | 12 ++++------
.../starter/helix/HelixInstanceDataManager.java | 9 +++++++-
19 files changed, 54 insertions(+), 83 deletions(-)
rename {pinot-common/src/main/java/org/apache/pinot/common/metadata =>
pinot-core/src/main/java/org/apache/pinot/core/realtime/stream}/RowMetadata.java
(97%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
