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 (16d36f1 -> a87decb)
Date Tue, 17 Dec 2019 00:38:05 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 16d36f1  MINOR: Adjust `testClientDisconnectionUpdatesRequestMetrics` to also test
small response case (#7754)
     add a87decb  KAFKA-9113: Extract clients from tasks to record collectors (#7833)

No new revisions were added by this update.

Summary of changes:
 .../processor/internals/StandbyContextImpl.java    |  48 +---
 .../streams/processor/internals/StreamTask.java    |   3 +-
 ...KStreamSessionWindowAggregateProcessorTest.java |   6 +-
 .../processor/internals/StreamTaskTest.java        |  13 +-
 .../AbstractRocksDBSegmentedBytesStoreTest.java    |   4 +-
 .../ChangeLoggingKeyValueBytesStoreTest.java       |  62 ++---
 .../ChangeLoggingSessionBytesStoreTest.java        |  47 ++--
 ...geLoggingTimestampedKeyValueBytesStoreTest.java |  75 +++---
 ...angeLoggingTimestampedWindowBytesStoreTest.java |  61 ++---
 .../ChangeLoggingWindowBytesStoreTest.java         |  46 ++--
 .../CompositeReadOnlyKeyValueStoreTest.java        |  10 +-
 .../state/internals/InMemorySessionStoreTest.java  |   1 +
 .../state/internals/KeyValueSegmentsTest.java      |   4 +-
 .../MeteredTimestampedWindowStoreTest.java         |   4 +-
 .../state/internals/MeteredWindowStoreTest.java    |   4 +-
 .../state/internals/RocksDBSessionStoreTest.java   |   4 +-
 .../state/internals/RocksDBWindowStoreTest.java    | 106 ++++----
 .../state/internals/SegmentIteratorTest.java       |   4 +-
 .../state/internals/SessionBytesStoreTest.java     |  87 ++----
 .../state/internals/StoreChangeLoggerTest.java     |  86 +++---
 .../internals/TimeOrderedKeyValueBufferTest.java   |   8 +-
 .../state/internals/TimestampedSegmentsTest.java   |   4 +-
 .../state/internals/WindowBytesStoreTest.java      | 294 +++++++--------------
 .../kafka/test/MockInternalProcessorContext.java   |  66 -----
 ...cordCollector.java => MockRecordCollector.java} |  47 +++-
 .../org/apache/kafka/test/StreamsTestUtils.java    |  20 ++
 26 files changed, 423 insertions(+), 691 deletions(-)
 rename streams/src/test/java/org/apache/kafka/test/{NoOpRecordCollector.java => MockRecordCollector.java}
(67%)


Mime
View raw message