This is an automated email from the ASF dual-hosted git repository.
github-merge-queue[bot] pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new e1a7e64b67 [Test][Connector-V2] Tolerate the aborted body write in GA4
oversized-response test (#12471)
e1a7e64b67 is described below
commit e1a7e64b6733d2b2cd4682190c753a81fac93bc2
Author: Goutam Adwant <[email protected]>
AuthorDate: Sat Oct 3 11:19:51 2026 +0000
[Test][Connector-V2] Tolerate the aborted body write in GA4
oversized-response test (#12471)
---
.../google/analytics4/GoogleAnalytics4SourceReaderTest.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git
a/seatunnel-connectors-v2/connector-google-analytics4/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4SourceReaderTest.java
b/seatunnel-connectors-v2/connector-google-analytics4/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4SourceReaderTest.java
index f5d5d5717a..10c28d81b8 100644
---
a/seatunnel-connectors-v2/connector-google-analytics4/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4SourceReaderTest.java
+++
b/seatunnel-connectors-v2/connector-google-analytics4/src/test/java/org/apache/seatunnel/connectors/seatunnel/google/analytics4/GoogleAnalytics4SourceReaderTest.java
@@ -202,7 +202,14 @@ class GoogleAnalytics4SourceReaderTest {
start(
exchange -> {
calls.incrementAndGet();
- reply(exchange, 200, new byte[2048]);
+ exchange.getResponseHeaders().set("Content-Type",
"application/json");
+ exchange.sendResponseHeaders(200, 2048);
+ try {
+ exchange.getResponseBody().write(new byte[2048]);
+ } catch (IOException expected) {
+ // The reader aborts once Content-Length exceeds
max_response_bytes, so
+ // the connection may already be reset or closed by
teardown here.
+ }
});
Map<String, Object> options = options();
options.put("max_response_bytes", 1024);
