You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by fm...@apache.org on 2026/04/01 15:25:12 UTC
(camel) 01/01: Fix flaky FromFileToFtpSplitParallelIT by removing FTP maxLogins limit
This is an automated email from the ASF dual-hosted git repository.
fmariani pushed a commit to branch fix/ftp-embedded-maxlogins
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6f87784d8b962e45ce232360fe73d82de03201ee
Author: Croway <fe...@gmail.com>
AuthorDate: Wed Apr 1 17:24:55 2026 +0200
Fix flaky FromFileToFtpSplitParallelIT by removing FTP maxLogins limit
Set maxLogins=0 (unlimited) on the embedded test FTP server.
The default maxLogins=10 caused FTP 421 rejections under CI load
when thread scheduling led to >10 concurrent logins.
---
.../test/infra/ftp/services/embedded/FtpEmbeddedInfraService.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/test-infra/camel-test-infra-ftp/src/main/java/org/apache/camel/test/infra/ftp/services/embedded/FtpEmbeddedInfraService.java b/test-infra/camel-test-infra-ftp/src/main/java/org/apache/camel/test/infra/ftp/services/embedded/FtpEmbeddedInfraService.java
index 7f1bc7476fff..bb6938d98562 100644
--- a/test-infra/camel-test-infra-ftp/src/main/java/org/apache/camel/test/infra/ftp/services/embedded/FtpEmbeddedInfraService.java
+++ b/test-infra/camel-test-infra-ftp/src/main/java/org/apache/camel/test/infra/ftp/services/embedded/FtpEmbeddedInfraService.java
@@ -130,7 +130,9 @@ public class FtpEmbeddedInfraService extends AbstractService implements FtpInfra
FtpServerFactory serverFactory = new FtpServerFactory();
serverFactory.setUserManager(userMgr);
serverFactory.setFileSystem(fsf);
- serverFactory.setConnectionConfig(new ConnectionConfigFactory().createConnectionConfig());
+ ConnectionConfigFactory connectionConfigFactory = new ConnectionConfigFactory();
+ connectionConfigFactory.setMaxLogins(0);
+ serverFactory.setConnectionConfig(connectionConfigFactory.createConnectionConfig());
ListenerFactory factory = new ListenerFactory();
// If port was already assigned (restart scenario), reuse it; otherwise get a new one