Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
1.5.0
-
None
Description
In LimitedConnectionsFileSystem#createStream, we get the outputLimit incorrectly.
private <T extends StreamWithTimeout> T createStream( final SupplierWithException<T, IOException> streamOpener, final HashSet<T> openStreams, final boolean output) throws IOException { final int outputLimit = output && maxNumOpenInputStreams > 0 ? maxNumOpenOutputStreams : Integer.MAX_VALUE; /*....*/ }
should be
private <T extends StreamWithTimeout> T createStream( final SupplierWithException<T, IOException> streamOpener, final HashSet<T> openStreams, final boolean output) throws IOException { final int outputLimit = output && maxNumOpenOutputStreams > 0 ? maxNumOpenOutputStreams : Integer.MAX_VALUE; /*....*/ }
Attachments
Issue Links
- links to