diff --git a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockTokenWithDFS.java b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockTokenWithDFS.java
index 428e252839cb6..f6243cdebbdbb 100644
--- a/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockTokenWithDFS.java
+++ b/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/blockmanagement/TestBlockTokenWithDFS.java
@@ -582,6 +582,9 @@ protected void doTestRead(Configuration conf, MiniDFSCluster cluster,
 
     // restart the namenode to allow DFSClient to re-fetch tokens
     cluster.restartNameNode(0);
+    // Reopen closed streams
+    in1 = fs.open(fileToRead);
+    in3 = fs.open(fileToRead);
     // verify blockSeekTo() works again (by transparently re-fetching
     // tokens from namenode)
     in1.seek(0);