Commit 5a8e4ee4 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Remove host and port from sftp link

parent dd4630c2
Pipeline #10567 passed with stages
in 9 minutes and 21 seconds
......@@ -136,7 +136,7 @@ class KafkaTopology(private val settings: SettingsLoader) {
val value = resource.getProperty(RICO.identifier).literal
for (file in files) {
if (file.contains(value.string)) {
link = "sftp://${}:${settings.sftpSettings.port}:$file"
link = "sftp:$file"
val literal = data.first.createLiteral(link)
addedStatements.add(StatementImpl(data.second, EBUCORE.locator, literal))
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment