kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (8f639eb -> 2298c7f)
Date Sat, 19 Oct 2019 20:46:16 GMT
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(-)


Mime
View raw message