Commit 2aaf0dd4 authored by Jonas Waeber's avatar Jonas Waeber
Browse files

Merge branch 'master' of...

Merge branch 'master' of
parents b37007f8 452ac137
Pipeline #16387 passed with stages
in 5 minutes and 26 seconds
......@@ -240,9 +240,7 @@ class KafkaTopology(private val settings: SettingsLoader) {
for (extension in fileExtensions) {
val filePath = "$sftpBasePath/${data.first.second.recordSetId}/$type/$value.$extension"
if (sftpClient.exists(filePath)) {
log.warn("File Exists: $filePath.")
link = "${Constant.sftpPathPrefix}$filePath"
if (type == Constant.mediaFolderName) {
val literal = ResourceFactory.createPlainLiteral(link)
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