Corrected PutFTP Remote Path Property EL
This closes
@@ -39,6 +39,7 @@ import org.apache.nifi.annotation.lifecycle.OnScheduled;
import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.components.ValidationContext;
import org.apache.nifi.components.ValidationResult;
+import org.apache.nifi.expression.ExpressionLanguageScope;
import org.apache.nifi.flowfile.FlowFile;
import org.apache.nifi.processor.ProcessContext;
import org.apache.nifi.processor.ProcessorInitializationContext;
@@ -71,6 +72,11 @@ public class PutFTP extends PutFileTransfer<FTPTransfer> {
private List<PropertyDescriptor> properties;
+ // PutFileTransfer.onTrigger() uses FlowFile attributes
+ public static final PropertyDescriptor REMOTE_PATH = new PropertyDescriptor.Builder()
+ .fromPropertyDescriptor(FTPTransfer.REMOTE_PATH)
+ .expressionLanguageSupported(ExpressionLanguageScope.FLOWFILE_ATTRIBUTES).build();
+
@Override
protected void init(final ProcessorInitializationContext context) {
final List<PropertyDescriptor> properties = new ArrayList<>();
@@ -78,7 +84,7 @@ public class PutFTP extends PutFileTransfer<FTPTransfer> {
properties.add(FTPTransfer.PORT);
properties.add(FTPTransfer.USERNAME);
properties.add(FTPTransfer.PASSWORD);
- properties.add(FTPTransfer.REMOTE_PATH);
+ properties.add(REMOTE_PATH);
properties.add(FTPTransfer.CREATE_DIRECTORY);
properties.add(FTPTransfer.BATCH_SIZE);
properties.add(FTPTransfer.CONNECTION_TIMEOUT);
