goutamadwant opened a new issue, #12851:
URL: https://github.com/apache/seatunnel/issues/12851

   ### Search before asking
   
   - [x] I had searched in the 
[issues](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22bug%22)
 and found no similar issues.
   
   ### What happened
   
   `all-connectors-it-6` sometimes runs into its 2h30m timeout with 
`FlussSinkIT` as the last test class. The SeaTunnel job in 
`container.executeJob(...)` never returns. This happened in about 4% of it-6 
runs on my fork since 2026-09-16, on JDK 8, 11 and 17 and on Spark, Flink and 
Zeta.
   
   In each hung run the coordinator log shows `Registered table ... id N` but 
never `New table: ... with id N`, so the table's bucket has no leader and the 
sink writer waits for one forever. This is apache/fluss#1018 in the 
`fluss/fluss:0.7.0` test server: the coordinator only handles a table creation 
on `NODE_CHANGED`, so if its ZooKeeper cache first reads the table znode after 
the data was written, the creation is never processed. It is fixed in Fluss 1.0 
(apache/fluss#2710).
   
   The e2e tests have no timeout, so one lost table costs the whole job.
   
   Examples: [JDK 17 
run](https://github.com/goutamadwant/seatunnel/actions/runs/38504080866/job/115660511748),
 [JDK 11 
run](https://github.com/goutamadwant/seatunnel/actions/runs/38090519266/job/114350797450).
   
   ### SeaTunnel Version
   
   dev
   
   ### SeaTunnel Config
   
   ```conf
   # connector-fluss-e2e: fake_to_fluss.conf / fake_to_multipletable_fluss.conf
   ```
   
   ### Running Command
   
   ```shell
   ./mvnw verify -DskipUT=true -DskipIT=false -Pci -pl :connector-fluss-e2e -am 
-Dit.test=FlussSinkIT
   ```
   
   ### Error Exception
   
   ```log
   coordinator: Registered table assignment {0=[0]} for table id 27.
   coordinator: Registered table fluss_tb_table1 for database fluss_db_test
     (no "TableManager - New table: ... with id 27")
   AbstractTestContainer - Execute command in container[...]
     ... no further test output until the job is cancelled at 2h30m
   ```
   
   ### Zeta or Flink or Spark Version
   
   All engines (E2E test server issue).
   
   ### Java or Scala Version
   
   _No response_
   
   ### Screenshots
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [x] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [x] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to