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

davidzollo 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 7fd11cdd7f [Test][E2E] Isolate HTTP binary assert case (#11432)
7fd11cdd7f is described below

commit 7fd11cdd7f25f06a9a9961ed5825082397ee7748
Author: Daniel <[email protected]>
AuthorDate: Wed Jul 15 20:52:40 2026 +0800

    [Test][E2E] Isolate HTTP binary assert case (#11432)
    
    Co-authored-by: DanielLeens <[email protected]>
---
 .../org/apache/seatunnel/e2e/connector/http/HttpIT.java     | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

diff --git 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/java/org/apache/seatunnel/e2e/connector/http/HttpIT.java
 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/java/org/apache/seatunnel/e2e/connector/http/HttpIT.java
index 0407e9d203..ba2b2fe3e3 100644
--- 
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/java/org/apache/seatunnel/e2e/connector/http/HttpIT.java
+++ 
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-http-e2e/src/test/java/org/apache/seatunnel/e2e/connector/http/HttpIT.java
@@ -365,10 +365,17 @@ public class HttpIT extends TestSuiteBase implements 
TestResource {
         // http airtable source
         Container.ExecResult execResult22 = 
container.executeJob("/airtable_json_to_assert.conf");
         Assertions.assertEquals(0, execResult22.getExitCode());
+    }
 
-        // http binary download
-        Container.ExecResult execResult23 = 
container.executeJob("/http_binary_to_assert.conf");
-        Assertions.assertEquals(0, execResult23.getExitCode());
+    /**
+     * Run the binary download case in a fresh container so the longest HTTP 
source path does not
+     * inherit accumulated runtime pressure from the broader source-to-assert 
matrix.
+     */
+    @TestTemplate
+    public void testBinarySourceToAssertSink(TestContainer container)
+            throws IOException, InterruptedException {
+        Container.ExecResult execResult = 
container.executeJob("/http_binary_to_assert.conf");
+        Assertions.assertEquals(0, execResult.getExitCode());
     }
 
     @TestTemplate

Reply via email to