apache / apache/pekko-connectors

FtpsWithProxyStageTest: fromPath

Open
#498 0 comments 0 reactions 0 assignees View on GitHub
flaky test ftp
Dominant language
Scala
Stars
82
Forks
50
Avg merge
1d 2h
Merged PRs (30d)
78

Description

```
--> [org.apache.pekko.stream.connectors.ftp.FtpsWithProxyStageTest: fromPath] Start of log messages of test that failed with assertion failed: timeout (30 seconds) during fishForMessage, hint: OnNext(_) or OnComplete
<-- [org.apache.pekko.stream.connectors.ftp.FtpsWithProxyStageTest: fromPath] End of log messages of test that failed with assertion failed: timeout (30 seconds) during fishForMessage, hint: OnNext(_) or OnComplete
02:26:23.451 INFO [default-dispatcher-6] o.a.pekko.event.slf4j.Slf4jLogger Slf4jLogger started
02:26:23.452 DEBUG [default-dispatcher-6] org.apache.pekko.event.EventStream logger log1-Slf4jLogger started
02:26:23.452 DEBUG [default-dispatcher-6] org.apache.pekko.event.EventStream Default Loggers started
02:26:23.475 DEBUG [default-dispatcher-6] zation(pekko://pekko-connectors-ftp) Replacing JavaSerializer with DisabledJavaSerializer, due to `pekko.actor.allow-java-serialization = off`.
02:26:23.476 INFO [pool-1-thread-1 ] o.a.p.s.c.t.j.LogCapturingJunit4 Logging started for test [org.apache.pekko.stream.connectors.ftp.FtpsWithProxyStageTest: fromPath]
02:26:23.477 DEBUG [default-dispatcher-7] o.apache.pekko.actor.ActorSystemImpl Dispatcher id [pekko.stream.materializer.blocking-io-dispatcher] is an alias, actual dispatcher will be [pekko.actor.default-blocking-io-dispatcher]
02:26:33.450 ERROR [1:2222-1708223073451] n.s.sshj.transport.TransportImpl Dying because - Broken transport; encountered EOF
net.schmizz.sshj.transport.TransportException: Broken transport; encountered EOF
at net.schmizz.sshj.transport.Reader.run(Reader.java:58)
02:26:52.318 ERROR [1:2222-1708223092317] n.s.sshj.transport.TransportImpl Dying because - Broken transport; encountered EOF
net.schmizz.sshj.transport.TransportException: Broken transport; encountered EOF
at net.schmizz.sshj.transport.Reader.run(Reader.java:58)
[error] Test org.apache.pekko.stream.connectors.ftp.FtpsWithProxyStageTest.fromPath failed: java.lang.AssertionError: assertion failed: timeout (30 seconds) during fishForMessage, hint: OnNext(_) or OnComplete, took 30.036 sec
[error] at scala.Predef$.assert(Predef.scala:279)
[error] at org.apache.pekko.testkit.TestKitBase.recv$1(TestKit.scala:523)
[error] at org.apache.pekko.testkit.TestKitBase.fishForMessage(TestKit.scala:527)
[error] at org.apache.pekko.testkit.TestKitBase.fishForMessage$(TestKit.scala:517)
[error] at org.apache.pekko.testkit.TestKit.fishForMessage(TestKit.scala:982)
[error] at org.apache.pekko.stream.testkit.TestSubscriber$ManualProbe.expectNextOrComplete(StreamTestKit.scala:623)
[error] at org.apache.pekko.stream.connectors.ftp.CommonFtpStageTest.fromPath(CommonFtpStageTest.java:87)
[error] at org.apache.pekko.stream.connectors.ftp.FtpsWithProxyStageTest.fromPath(FtpsWithProxyStageTest.java:48)
[error] ...
```

Contributor guide

Open the contributing guide

Research direction

Start by running FtpsWithProxyStageTest.fromPath and inspect the failure path through CommonFtpStageTest.fromPath, especially the 30-second fishForMessage timeout and SSHJ broken-transport EOF messages. Determine why the FTPS proxy test does not produce OnNext or OnComplete, then verify that the test completes reliably.

Written by the indexing model from the issue text.

Assessment

Tech stack
scala
Domain
networking, testing-qa
Issue type
Bug
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
25/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.