This is an automated email from the ASF dual-hosted git repository.

qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git

commit 2feb0ce1ae8c54883ba2fb64d99e83897e3e1c01
Author: 仲炜 <[email protected]>
AuthorDate: Sat Mar 28 15:27:09 2020 +0800

    try to fix windows test
---
 .../src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java
 
b/flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java
index d58d38d..1ecb4bb 100644
--- 
a/flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java
+++ 
b/flink-tsfile/src/main/java/org/apache/iotdb/flink/tsfile/TsFileInputFormat.java
@@ -102,7 +102,7 @@ public class TsFileInputFormat<T> extends 
FileInputFormat<T> implements ResultTy
                                        hadoopConf);
                        } else {
                                // Local File System
-                               in = new 
DefaultTsFileInput(Paths.get(currentSplit.getPath().getPath()));
+                               in = new 
DefaultTsFileInput(Paths.get(currentSplit.getPath().toUri()));
                        }
                } catch (URISyntaxException e) {
                        throw new FlinkRuntimeException(e);

Reply via email to