Hello everyone, thanks for the great library. However, this is the first issue I had with it. Actually, my program runs for a while and crash at the same point at each run, I use Pluto for interacting with my own library that use ThreadsX.jl. I only utilize ThreadsX.foreach and sort features. Number of threads assigned to process remains same, memory usage remains same however, I get this stacktrace;
Worker 2 terminated.
Unhandled Task ERROR: IOError: read: connection reset by peer (ECONNRESET)
Stacktrace:
[1] wait_readnb(x::Sockets.TCPSocket, nb::Int64)
@ Base ./stream.jl:410
[2] (::Base.var"#wait_locked#680")(s::Sockets.TCPSocket, buf::IOBuffer, nb::Int64)
@ Base ./stream.jl:947
[3] unsafe_read(s::Sockets.TCPSocket, p::Ptr{UInt8}, nb::UInt64)
@ Base ./stream.jl:953
[4] unsafe_read
@ ./io.jl:759 [inlined]
[5] unsafe_read(s::Sockets.TCPSocket, p::Base.RefValue{NTuple{4, Int64}}, n::Int64)
@ Base ./io.jl:758
[6] read!
@ ./io.jl:760 [inlined]
[7] deserialize_hdr_raw
@ /Applications/Julia-1.8.app/Contents/Resources/julia/share/julia/stdlib/v1.8/Distributed/src/messages.jl:167 [inlined]
[8] message_handler_loop(r_stream::Sockets.TCPSocket, w_stream::Sockets.TCPSocket, incoming::Bool)
@ Distributed /Applications/Julia-1.8.app/Contents/Resources/julia/share/julia/stdlib/v1.8/Distributed/src/process_messages.jl:172
[9] process_tcp_streams(r_stream::Sockets.TCPSocket, w_stream::Sockets.TCPSocket, incoming::Bool)
@ Distributed /Applications/Julia-1.8.app/Contents/Resources/julia/share/julia/stdlib/v1.8/Distributed/src/process_messages.jl:133
[10] (::Distributed.var"#103#104"{Sockets.TCPSocket, Sockets.TCPSocket, Bool})()
@ Distributed ./task.jl:484
It seems like an internal issue, however, if there may be a potential cause that may trigger it, if you may point it out I may also check my code and provide more helpful information.
Hello everyone, thanks for the great library. However, this is the first issue I had with it. Actually, my program runs for a while and crash at the same point at each run, I use Pluto for interacting with my own library that use ThreadsX.jl. I only utilize
ThreadsX.foreachandsortfeatures. Number of threads assigned to process remains same, memory usage remains same however, I get this stacktrace;It seems like an internal issue, however, if there may be a potential cause that may trigger it, if you may point it out I may also check my code and provide more helpful information.