[FLINK-3424] [tests] Close InputStream in FileStateBackendTest#validateBytesInStream
This closes #1653 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7278e875 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7278e875 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7278e875 Branch: refs/heads/master Commit: 7278e875bd57712a3a5c6069eac491834684c3bf Parents: 06e3dd1 Author: zentol <s.mo...@web.de> Authored: Wed Feb 17 11:46:30 2016 +0100 Committer: Stephan Ewen <se...@apache.org> Committed: Thu Feb 18 12:39:04 2016 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/runtime/state/FileStateBackendTest.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/7278e875/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java index e7bf80e..5645038 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/state/FileStateBackendTest.java @@ -266,6 +266,7 @@ public class FileStateBackendTest extends StateBackendTestBase<FsStateBackend> { assertEquals("not enough data", holder.length, pos); assertEquals("too much data", -1, is.read()); assertArrayEquals("wrong data", data, holder); + is.close(); } }
