[
https://issues.apache.org/jira/browse/FLINK-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16264350#comment-16264350
]
ASF GitHub Bot commented on FLINK-8125:
---------------------------------------
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5059
Does this remove all checkstyle violations in core.fs? If so, please remove
the exlcusion in `/tools/maven/suppressions-core.xml`.
```
<suppress
files="(.*)core[/\\]fs[/\\](.*)"
checks="NewlineAtEndOfFile|RegexpSingleline|TodoComment|RedundantImport|ImportOrder|RedundantModifier|JavadocMethod|JavadocParagraph|JavadocType|JavadocStyle|PackageName|TypeNameCheck|ConstantNameCheck|StaticVariableNameCheck|MemberNameCheck|MethodNameCheck|ParameterName|LocalFinalVariableName|LocalVariableName|LeftCurly|UpperEll|FallThrough|reliefPattern|SimplifyBooleanExpression|EmptyStatement|ModifierOrder|EmptyLineSeparator|WhitespaceAround|WhitespaceAfter|NoWhitespaceAfter|NoWhitespaceBefore|OperatorWrap|ParenPad"/>
<!--Only additional checks for test sources. Those checks were present
in the "pre-strict" checkstyle but were not applied to test sources. We do not
want to suppress them for sources directory-->
<suppress
files="(.*)test[/\\](.*)core[/\\]fs[/\\](.*)"
checks="AvoidStarImport"/>
```
> Support limiting the number of open FileSystem connections
> ----------------------------------------------------------
>
> Key: FLINK-8125
> URL: https://issues.apache.org/jira/browse/FLINK-8125
> Project: Flink
> Issue Type: Improvement
> Components: Core
> Reporter: Stephan Ewen
> Assignee: Stephan Ewen
> Fix For: 1.5.0, 1.4.1
>
>
> We need a way to limit the number of streams that Flink FileSystems
> concurrently open.
> For example, for very small HDFS clusters with few RPC handlers, a large
> Flink job trying to build up many connections during a checkpoint causes
> failures due to rejected connections.
> I propose to add a file system that can wrap another existing file system The
> file system may track the progress of streams and close streams that have
> been inactive for too long, to avoid locked streams of taking up the complete
> pool.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
