This is an automated email from the ASF dual-hosted git repository. github-merge-queue[bot] pushed a commit to branch gh-readonly-queue/dev/pr-12471-f80794289d565e002a63844e6cf5f59d3d48076a in repository https://gitbox.apache.org/repos/asf/seatunnel.git
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);
