[ https://issues.apache.org/jira/browse/FLINK-4259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Márton Balassi closed FLINK-4259. --------------------------------- Resolution: Fixed Fix Version/s: 1.2.0 Fixed via 5d7e949. > Unclosed FSDataOutputStream in FileCache#copy() > ----------------------------------------------- > > Key: FLINK-4259 > URL: https://issues.apache.org/jira/browse/FLINK-4259 > Project: Flink > Issue Type: Bug > Reporter: Ted Yu > Assignee: Neelesh Srinivas Salian > Priority: Minor > Fix For: 1.2.0 > > > {code} > try { > FSDataOutputStream lfsOutput = tFS.create(targetPath, false); > FSDataInputStream fsInput = sFS.open(sourcePath); > IOUtils.copyBytes(fsInput, lfsOutput); > {code} > The FSDataOutputStream lfsOutput should be closed upon exit. -- This message was sent by Atlassian JIRA (v6.3.4#6332)