This is an automated email from the ASF dual-hosted git repository.
kharekartik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from a385e28c3d [Minor bugfix] Decrypt file in minion task executor when
downloading from servers (#13178)
add 9e1246de98 Enhance Kinesis consumer (#12806)
No new revisions were added by this update.
Summary of changes:
.../core/realtime/stream/StreamConfigTest.java | 27 ---
pinot-integration-tests/pom.xml | 7 -
.../pinot-stream-ingestion/pinot-kinesis/pom.xml | 60 +------
.../pinot/plugin/stream/kinesis/KinesisConfig.java | 3 +-
.../plugin/stream/kinesis/KinesisConsumer.java | 200 +++++++--------------
.../kinesis/KinesisStreamMetadataProvider.java | 6 +-
.../plugin/stream/kinesis/KinesisConsumerTest.java | 85 +++++----
.../pinot/spi/stream/PartitionGroupConsumer.java | 6 +-
.../org/apache/pinot/spi/stream/StreamConfig.java | 9 +-
9 files changed, 116 insertions(+), 287 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
