This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 8f639eb KAFKA-9041; Flaky Test
LogCleanerIntegrationTest#testIsThreadFailed (#7542)
add 2298c7f KAFKA-8964: Refactor thread-level metrics depending on
built-in metrics version (#7474)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/StreamsConfig.java | 6 +-
.../kstream/internals/KStreamAggregate.java | 6 +-
.../kstream/internals/KStreamKStreamJoin.java | 6 +-
.../internals/KStreamKTableJoinProcessor.java | 6 +-
.../streams/kstream/internals/KStreamReduce.java | 6 +-
.../internals/KStreamSessionWindowAggregate.java | 5 +-
.../kstream/internals/KStreamWindowAggregate.java | 5 +-
.../kstream/internals/KTableKTableInnerJoin.java | 6 +-
.../kstream/internals/KTableKTableLeftJoin.java | 6 +-
.../kstream/internals/KTableKTableOuterJoin.java | 6 +-
.../kstream/internals/KTableKTableRightJoin.java | 6 +-
.../streams/kstream/internals/KTableSource.java | 5 +-
.../ForeignJoinSubscriptionProcessorSupplier.java | 5 +-
...reignJoinSubscriptionSendProcessorSupplier.java | 9 +-
.../SubscriptionStoreReceiveProcessorSupplier.java | 6 +-
.../processor/internals/RecordCollectorImpl.java | 7 +-
.../processor/internals/RecordDeserializer.java | 8 +-
.../streams/processor/internals/RecordQueue.java | 5 +-
.../streams/processor/internals/StreamTask.java | 5 +-
.../internals/metrics/StreamsMetricsImpl.java | 33 +-
.../processor/internals/metrics/ThreadMetrics.java | 246 +++++++++------
.../state/internals/metrics/NamedCacheMetrics.java | 8 +-
.../apache/kafka/streams/StreamsConfigTest.java | 6 +-
.../integration/MetricsIntegrationTest.java | 64 +++-
.../kstream/internals/KGroupedStreamImplTest.java | 65 +++-
.../kstream/internals/KStreamKStreamJoinTest.java | 31 +-
.../kstream/internals/KStreamKTableJoinTest.java | 65 +++-
...KStreamSessionWindowAggregateProcessorTest.java | 62 +++-
.../internals/KStreamWindowAggregateTest.java | 22 +-
.../internals/KTableKTableInnerJoinTest.java | 24 +-
.../internals/KTableKTableLeftJoinTest.java | 22 +-
.../internals/KTableKTableOuterJoinTest.java | 22 +-
.../internals/KTableKTableRightJoinTest.java | 28 +-
.../kstream/internals/KTableSourceTest.java | 35 +++
.../processor/internals/ProcessorNodeTest.java | 3 +-
.../processor/internals/RecordCollectorTest.java | 53 ++--
.../internals/RecordDeserializerTest.java | 3 +-
.../processor/internals/RecordQueueTest.java | 3 +-
.../streams/processor/internals/SinkNodeTest.java | 4 +-
.../processor/internals/StreamTaskTest.java | 233 +++++++++-----
.../processor/internals/StreamThreadTest.java | 197 +++++++++---
.../internals/metrics/StreamsMetricsImplTest.java | 33 +-
.../internals/metrics/ThreadMetricsTest.java | 345 +++++++++++++--------
.../streams/state/KeyValueStoreTestDriver.java | 3 +-
.../state/internals/SessionBytesStoreTest.java | 4 +-
.../state/internals/StoreChangeLoggerTest.java | 5 +-
.../state/internals/WindowBytesStoreTest.java | 4 +-
.../internals/metrics/NamedCacheMetricsTest.java | 2 +-
.../apache/kafka/streams/TopologyTestDriver.java | 20 +-
.../streams/processor/MockProcessorContext.java | 6 +-
50 files changed, 1234 insertions(+), 531 deletions(-)
