apache / apache/pekko-connectors
FtpsWithProxyStageTest: fromPath
- 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
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