This is an automated email from the ASF dual-hosted git repository.

chia7712 pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


    from ddab943b0ba KAFKA-18265: Move persister call outside of the lock (3/N) 
(#20316)
     add cfe483b7282 MINOR: Cleanup Trogdor Module (#20214)

No new revisions were added by this update.

Summary of changes:
 .../apache/kafka/trogdor/agent/AgentClient.java    |  5 +-
 .../org/apache/kafka/trogdor/basic/BasicNode.java  |  3 +-
 .../kafka/trogdor/common/StringFormatter.java      |  4 +-
 .../trogdor/coordinator/CoordinatorClient.java     |  5 +-
 .../kafka/trogdor/coordinator/TaskManager.java     | 17 ++---
 .../trogdor/fault/DegradedNetworkFaultSpec.java    |  3 +-
 .../org/apache/kafka/trogdor/fault/Kibosh.java     |  3 +-
 .../trogdor/fault/NetworkPartitionFaultWorker.java |  4 +-
 .../apache/kafka/trogdor/rest/ErrorResponse.java   | 23 +-----
 .../org/apache/kafka/trogdor/rest/TaskRequest.java |  9 +--
 .../apache/kafka/trogdor/rest/TasksRequest.java    |  5 +-
 .../apache/kafka/trogdor/rest/TasksResponse.java   |  3 +-
 .../org/apache/kafka/trogdor/task/TaskSpec.java    |  3 +-
 .../trogdor/workload/ConfigurableProducerSpec.java |  4 +-
 .../trogdor/workload/ConnectionStressSpec.java     |  4 +-
 .../trogdor/workload/ConnectionStressWorker.java   | 11 ++-
 .../kafka/trogdor/workload/ConsumeBenchSpec.java   |  3 +-
 .../kafka/trogdor/workload/ConsumeBenchWorker.java |  7 +-
 .../trogdor/workload/ExternalCommandSpec.java      |  7 +-
 .../apache/kafka/trogdor/workload/Histogram.java   |  3 +-
 .../kafka/trogdor/workload/PartitionsSpec.java     |  7 +-
 .../kafka/trogdor/workload/ProduceBenchSpec.java   |  4 +-
 .../kafka/trogdor/workload/RandomComponent.java    | 18 +----
 .../trogdor/workload/RoundTripWorkloadSpec.java    |  4 +-
 .../trogdor/workload/ShareConsumeBenchSpec.java    |  3 +-
 .../trogdor/workload/SustainedConnectionSpec.java  |  4 +-
 .../workload/SustainedConnectionWorker.java        |  6 +-
 .../apache/kafka/trogdor/workload/TopicsSpec.java  |  5 +-
 .../org/apache/kafka/trogdor/agent/AgentTest.java  | 27 +++----
 .../trogdor/common/JsonSerializationTest.java      |  5 +-
 .../apache/kafka/trogdor/common/JsonUtilTest.java  |  5 +-
 .../kafka/trogdor/common/MiniTrogdorCluster.java   |  5 +-
 .../kafka/trogdor/common/StringExpanderTest.java   |  7 +-
 .../kafka/trogdor/common/StringFormatterTest.java  |  8 +--
 .../kafka/trogdor/common/WorkerUtilsTest.java      | 84 +++++++++++-----------
 .../kafka/trogdor/coordinator/CoordinatorTest.java |  5 +-
 .../apache/kafka/trogdor/task/SampleTaskSpec.java  |  5 +-
 .../trogdor/workload/ConsumeBenchSpecTest.java     | 21 +++---
 .../workload/ExternalCommandWorkerTest.java        |  4 +-
 .../trogdor/workload/PayloadGeneratorTest.java     | 17 +++--
 .../workload/ShareConsumeBenchSpecTest.java        | 13 ++--
 .../kafka/trogdor/workload/TopicsSpecTest.java     | 15 ++--
 42 files changed, 153 insertions(+), 245 deletions(-)

Reply via email to