diff --git a/src/main/java/io/cdap/plugin/batch/source/ftp/FTPBatchSource.java b/src/main/java/io/cdap/plugin/batch/source/ftp/FTPBatchSource.java index 46531c8..f9d53e4 100644 --- a/src/main/java/io/cdap/plugin/batch/source/ftp/FTPBatchSource.java +++ b/src/main/java/io/cdap/plugin/batch/source/ftp/FTPBatchSource.java @@ -262,7 +262,7 @@ public String getPath() { if (port == -1 && protocol.equals(SFTP_PROTOCOL)) { port = DEFAULT_SFTP_PORT; } - return UriBuilder.fromUri(urlInfo.toUri()).port(port).userInfo(null).toString(); + return UriBuilder.fromUri(urlInfo.toUri()).port(port).userInfo(null).build().toString(); } return path; }