Skip to content

Commit 1fb429b

Browse files
committed
Fix AI fix
Signed-off-by: Marvin Froeder <marvin@datasqrl.com>
1 parent 8fd2526 commit 1fb429b

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

flink-sql-runner/src/test/java/com/datasqrl/FlinkMainIT.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -258,13 +258,11 @@ private int instrument(final File src, final File dest) throws IOException {
258258

259259
dest.getParentFile().mkdirs();
260260
try (final InputStream input = new FileInputStream(src);
261-
final OutputStream output = new FileOutputStream(dest)) {
261+
final OutputStream output = new FileOutputStream(dest)) {
262262
return instrumenter.instrumentAll(input, output, src.getAbsolutePath());
263263
} catch (final IOException e) {
264264
dest.delete();
265265
throw e;
266-
} finally {
267-
input.close();
268266
}
269267
}
270268

0 commit comments

Comments
 (0)