diff --git a/flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java b/flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java index 4a52eea5d768b..6bff9dbc7e05c 100644 --- a/flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java +++ b/flink-java/src/test/java/org/apache/flink/api/java/io/TextInputFormatTest.java @@ -108,7 +108,7 @@ public void testNestedFileRead() { } File parentDir = new File("tmp"); - TextInputFormat inputFormat = new TextInputFormat(new Path(parentDir.toURI().toString())); + TextInputFormat inputFormat = new TextInputFormat(new Path(parentDir.toURI())); inputFormat.setNestedFileEnumeration(true); inputFormat.setNumLineSamples(10);