Hello friends,   I wrote a custom processor and now wanted to add a custom controller. The problem is, that the properties I wrote for the controller do not appear when I create the service. I followed the structure of this controller: https://github.com/Automna/NiFi/blob/master/nifi-rel-nifi-1.1.2/nifi-nar-bundles/nifi-standard-services/nifi-dbcp-service-bundle/nifi-dbcp-service/src/main/java/org/apache/nifi/dbcp/DBCPConnectionPool.java     Here is what I did so far: public class MyNewControllerService extends AbstractControllerService implements MyControllerService { public static final PropertyDescriptor USERNAME = new PropertyDescriptor.Builder() .name("Username") .expressionLanguageSupported(ExpressionLanguageScope.NONE) .displayName("Set username") .required(true) .defaultValue("User") .description("Username to login to graph service") .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .build(); public static final PropertyDescriptor PASSWORD = new PropertyDescriptor.Builder(). name("Password") .expressionLanguageSupported(ExpressionLanguageScope.NONE) .displayName("Set password") .required(true) .defaultValue("password") .description("Password to login to graph service") .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .build(); public static final PropertyDescriptor URL = new PropertyDescriptor.Builder(). name("ApiUrl") .expressionLanguageSupported(ExpressionLanguageScope.NONE) .displayName("Set url") .required(true) .defaultValue("url") .description("Full url to api") .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .build(); private static final List<PropertyDescriptor> properties; static { final List<PropertyDescriptor> props = new ArrayList<>(); props.add(USERNAME); props.add(PASSWORD); props.add(URL); properties = Collections.unmodifiableList(props); } OkHttpClient client = new OkHttpClient(); private static ObjectMapper mapper = new ObjectMapper(); @Override protected List<PropertyDescriptor> getSupportedPropertyDescriptors() { return properties; } @OnEnabled public void onConfigured(final ConfigurationContext context) throws InitializationException { final String user = context.getProperty(USERNAME).getValue(); final String password = context.getProperty(PASSWORD).getValue(); final String url = context.getProperty(URL).getValue(); What is missing that I only get a blank properties page? ... View more

Hello there,   I have flowfiles with json content, which I transform before using them to send a post request with InvokeHTTP. I have an attribute "url_value" which I can use to determine my "api_value". For now I use EvaluateJsonPath to add those values to the flowfile attributes, then I use UpdateAttribute where I have set some rules to get the correct api_value. Now my question: how do I get the value back into my content? If I use AttributesToJSON, it overrides all previous content, therefore I need to have extracted all necessary attributes with EvaluateJsonPath before. This is not a very elegant solution since there can be many entries and I actually only need to update one of them! Is there no processor similar to UpdateAttribute but for flowfile content? How could I use JoltTransformJSON to change a value depending on another attribute?   Edit: I would need something like if url_value:contains("webpage1") set api_value to "wepage1" elseif url_value:contains("webpage2") set api_value to "webpage2" and so on and so forth   I appreciate any hints. Thanks ... View more