This is an automated email from the ASF dual-hosted git repository.
xiangfu0 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from f60f17fd701 Reject cross-table functions under row-level security
(#20169)
add 61e770d8a6a Rate-limit stream data-loss reports and fail re-ingestion
on data loss (#20020)
No new revisions were added by this update.
Summary of changes:
.../realtime/RealtimeSegmentDataManager.java | 90 ++++++-
.../realtime/RealtimeSegmentDataManagerTest.java | 199 +++++++++++++++
.../kafka40/KafkaPartitionLevelConsumer.java | 61 ++++-
...fkaPartitionLevelConsumerDataLossCheckTest.java | 243 ++++++++++++++++++
...titionLevelConsumerDataLossIntegrationTest.java | 75 +++++-
.../writer/StatelessRealtimeSegmentWriter.java | 9 +
.../writer/StatelessRealtimeSegmentWriterTest.java | 280 +++++++++++++++++++++
7 files changed, 942 insertions(+), 15 deletions(-)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-4.0/src/test/java/org/apache/pinot/plugin/stream/kafka40/KafkaPartitionLevelConsumerDataLossCheckTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
