Commit 452ac137 authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files

remove obsolete logs

parent bc3aa80d
Pipeline #16242 passed with stages
in 5 minutes and 21 seconds
......@@ -241,9 +241,7 @@ class KafkaTopology(private val settings: SettingsLoader) {
for (extension in fileExtensions) {
val filePath = "$sftpBasePath/${data.first.second.recordSetId}/$type/$value.$extension"
log.warn(filePath)
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