TyrantLucifer commented on code in PR #2980:
URL:
https://github.com/apache/incubator-seatunnel/pull/2980#discussion_r985634997
##########
seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java:
##########
@@ -237,7 +236,7 @@ public void beginTransaction(Long checkpointId) {
*/
public List<String> getTransactionIdFromStates(List<FileSinkState>
fileStates) {
String[] pathSegments = new String[]{textFileSinkConfig.getPath(),
Constant.SEATUNNEL, jobId};
- String jobDir = String.join(File.separator, pathSegments) + "/";
+ String jobDir = String.join("/", pathSegments) + "/";
Review Comment:
Because the `File.separator` that in Windows is `\`, so the path be joined
it will be like this:
`/tmp/seatunnel/dist\xxxx.txt`
this path hdfs protocol is not recognized, I have tried to change the path
to the windows format like `\tmp\seatunnel\dist\xxx.txt`, but the hdfs protocol
still can not recognize. So in order to run the test cases related to the file
connector in the windows environment I decided to change it.
The purpose of this pr is to be able to debug better in the windows
environment, there is no impact on the normal function.
If you think it is not necessary, we can close it.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
