KAFKA-13987: Isolate REST request timeout changes in Connect integration tests (#12291)
This causes the artificial reductions in the Connect REST request timeout to be more isolated. Specifically, they now only take place in the tests that need them (instead of any tests that happen to be running after the reduction has taken place and before it has been reset), and they are only performed for the requests that are expected to time out, before being immediately reset. This should help reduce spurious test failures (especially in slow environments like Jenkins) for all Connect integration tests that interact with the REST API, not just the BlockingConnectorTest test suite. Reviewers: Bruno Cadonna <cadonna@apache.org>
显示
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Connect.java 2 个添加, 7 个删除...c/main/java/org/apache/kafka/connect/runtime/Connect.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java 2 个添加, 2 个删除...rc/main/java/org/apache/kafka/connect/runtime/Worker.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java 20 个添加, 6 个删除...ava/org/apache/kafka/connect/runtime/rest/RestServer.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectResource.java 40 个添加, 0 个删除...kafka/connect/runtime/rest/resources/ConnectResource.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java 9 个添加, 2 个删除...nect/runtime/rest/resources/ConnectorPluginsResource.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java 9 个添加, 17 个删除...ka/connect/runtime/rest/resources/ConnectorsResource.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResource.java 6 个添加, 1 个删除...kafka/connect/runtime/rest/resources/LoggingResource.java
- connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/RootResource.java 6 个添加, 1 个删除...he/kafka/connect/runtime/rest/resources/RootResource.java
- connect/runtime/src/test/java/org/apache/kafka/connect/integration/BlockingConnectorTest.java 31 个添加, 16 个删除...ache/kafka/connect/integration/BlockingConnectorTest.java
- connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java 10 个添加, 0 个删除...e/kafka/connect/util/clusters/EmbeddedConnectCluster.java
- connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/WorkerHandle.java 13 个添加, 3 个删除.../org/apache/kafka/connect/util/clusters/WorkerHandle.java
加载中
想要评论请 注册 或 登录