Member since
04-11-2016
471
Posts
325
Kudos Received
118
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
2070 | 03-09-2018 05:31 PM | |
2629 | 03-07-2018 09:45 AM | |
2528 | 03-07-2018 09:31 AM | |
4384 | 03-03-2018 01:37 PM | |
2468 | 10-17-2017 02:15 PM |
03-07-2018
09:45 AM
1 Kudo
Hi @Chad Woodhead, This property needs to be set if and only if you are doing S2S using RAW protocol. Any reason not to use HTTP protocol for S2S? This way, you don't have anything to set and it'll work OOTB with default configuration. If, however, you want to use RAW and you are configuring NiFi using Ambari, you don't need to use config groups, you can set the property to: {{nifi_node_host}} It's a placeholder that contains the FQDN of each node. Note that this property already has a default value generated if you let it blank (see the description of this property in Ambari). Unless you have a specific network configuration, the only property you would need to specify is nifi.remote.input.socket.port to define the port that will be used for RAW S2S. Hope this helps.
... View more
03-07-2018
09:37 AM
Hi @Amira khalifa, Why don't you want to define the schema or your target tables in the schema registry? You can use InferAvroSchema to help you initializing the schema, then you can adapt it and copy/paste it into the schema registry of your choice. Using InferAvroSchema for every single flow file you'll ingest can be costly in terms of performance and it's only inferring the schema on a subset of data: as you can see, the schema might not be completely correct to take into account all the possibilities. What you could do, even though it's not what I'd recommend as a long term solution, is to use expression language to update the avro schema generated as an attribute of your flow files. Hope this helps.
... View more
03-07-2018
09:31 AM
Hi @Manikandan Jeyabal, This is not possible at the moment. The number of threads used at one point in time can be set at NiFi level. There is no way to fix the size of the threads pool per Process Group. It could be an interesting feature, feel free to raise a JIRA on https://issues.apache.org/jira/projects/NIFI Hope this helps.
... View more
03-03-2018
01:37 PM
Hi, What are the RUNNING jobs that stop making progress? In particular are these jobs oozie-launcher jobs? You can check that by looking at the name of the jobs in the Scheduler view of the RM UI. Oozie has a non-intuitive way of launching jobs due to legacy behaviors from Hadoop 1 (note that this will be fixed with Oozie 5.x). In short, an Oozie action will launch an oozie-launcher job (1 AM container + 1 mapper) that will be responsible for actually launching the job that you defined in your Oozie action. In the end, your Oozie action will actually require two jobs from YARN point of view. When running multiple workflows at the same time, you could end with a lot of oozie-launcher jobs filling up the queue capacity and preventing the actual jobs to be launched (they will remain in ACCEPTED state). A common practice is to have a dedicated queue for oozie-launcher jobs created by Oozies workflows. This way you prevent this kind of deadlock situation. IIRC, you can set the queue for oozie-launcher jobs using oozie.launcher.mapred.job.queue.name. Hope this helps.
... View more
03-03-2018
10:16 AM
1 Kudo
Hi Jay, You need to provide a file such as https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/resources/TestExtractGrok/patterns You could also use the ConvertRecord processor with a GrokReader. In this case there is already a default pattern file pre-loaded with the reader. Hope this helps, Pierre
... View more
10-30-2017
11:01 AM
In case someone faces the same issue: in my case, I solved it by ensuring that 'atlas' user is known in Ranger.
... View more
10-17-2017
02:15 PM
1 Kudo
Hi @msumbul, The ConvertJsonToSQL processor has been developed to work with the SQL processors. The Hive processor is expecting a different naming convention on the attributes, instead of: sql.args.N.type/value it is expecting: hiveql.args.N.type/value The syntax between SQL and HQL are close enough and the generated query is also valid for Hive but the attributes need to be renamed. What you can do is to use an UpdateAttribute processor to have the expected attributes before using the PutHiveQL processor. Hope this helps.
... View more
09-19-2017
12:08 PM
2 Kudos
@Onkar Pathak You can use a GET for this. Example: GET http://localhost:8080/nifi-api/flow/process-groups/aa246331-015a-1000-fac3-b72f7046408b/controller-services Response: {"currentTime":"14:06:21 CEST","controllerServices":[{"revision":{"version":0},"id":"fbec5165-015a-1000-ef40-26bc04ec2b63","uri":"http://localhost:8080/nifi-api/controller-services/fbec5165-015a-1000-ef40-26bc04ec2b63","permissions":{"canRead":true,"canWrite":true},"bulletins":[],"component":{"id":"fbec5165-015a-1000-ef40-26bc04ec2b63","parentGroupId":"aa246331-015a-1000-fac3-b72f7046408b","name":"StandardHttpContextMap","type":"org.apache.nifi.http.StandardHttpContextMap","bundle":{"group":"org.apache.nifi","artifact":"nifi-http-context-map-nar","version":"1.4.0-SNAPSHOT"},"controllerServiceApis":[{"type":"org.apache.nifi.http.HttpContextMap","bundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}}],"comments":"","state":"DISABLED","persistsState":false,"restricted":false,"deprecated":false,"multipleVersionsAvailable":false,"properties":{"Maximum Outstanding Requests":"10000","Request Expiration":"1 min"},"descriptors":{"Maximum Outstanding Requests":{"name":"Maximum Outstanding Requests","displayName":"Maximum Outstanding Requests","description":"The maximum number of HTTP requests that can be outstanding at any one time. Any attempt to register an additional HTTP Request will cause an error","defaultValue":"5000","required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Request Expiration":{"name":"Request Expiration","displayName":"Request Expiration","description":"Specifies how long an HTTP Request should be left unanswered before being evicted from the cache and being responded to with a Service Unavailable status code","defaultValue":"1 min","required":true,"sensitive":false,"dynamic":false,"supportsEl":false}},"referencingComponents":[{"revision":{"version":0,"lastModifier":"anonymous"},"id":"fbec5167-015a-1000-998a-858ea9611244","permissions":{"canRead":true,"canWrite":true},"component":{"groupId":"fc7d4a17-015a-1000-7731-9659aaa9b098","id":"fbec5167-015a-1000-998a-858ea9611244","name":"HandleHttpRequest","type":"HandleHttpRequest","state":"STOPPED","properties":{"Listening Port":"9999","Hostname":"localhost","SSL Context Service":null,"HTTP Context Map":"fbec5165-015a-1000-ef40-26bc04ec2b63","Allowed Paths":null,"Default URL Character Set":"UTF-8","Allow GET":"true","Allow POST":"true","Allow PUT":"true","Allow DELETE":"true","Allow HEAD":"false","Allow OPTIONS":"false","Additional HTTP Methods":null,"Client Authentication":"No Authentication","container-queue-size":"50"},"descriptors":{"Listening Port":{"name":"Listening Port","displayName":"Listening Port","description":"The Port to listen on for incoming HTTP requests","defaultValue":"80","required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Hostname":{"name":"Hostname","displayName":"Hostname","description":"The Hostname to bind to. If not specified, will bind to all hosts","required":false,"sensitive":false,"dynamic":false,"supportsEl":false},"SSL Context Service":{"name":"SSL Context Service","displayName":"SSL Context Service","description":"The SSL Context Service to use in order to secure the server. If specified, the server will accept only HTTPS requests; otherwise, the server will accept only HTTP requests","allowableValues":[],"required":false,"sensitive":false,"dynamic":false,"supportsEl":false,"identifiesControllerService":"org.apache.nifi.ssl.RestrictedSSLContextService","identifiesControllerServiceBundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}},"HTTP Context Map":{"name":"HTTP Context Map","displayName":"HTTP Context Map","description":"The HTTP Context Map Controller Service to use for caching the HTTP Request Information","allowableValues":[{"allowableValue":{"displayName":"StandardHttpContextMap","value":"f6aa99d0-0159-1000-d428-5edef0de643e"},"canRead":true},{"allowableValue":{"displayName":"StandardHttpContextMap","value":"fbec5165-015a-1000-ef40-26bc04ec2b63"},"canRead":true},{"allowableValue":{"displayName":"StandardHttpContextMap","value":"fc7d8d0b-015a-1000-e0f4-d79e69229742"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false,"identifiesControllerService":"org.apache.nifi.http.HttpContextMap","identifiesControllerServiceBundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}},"Allowed Paths":{"name":"Allowed Paths","displayName":"Allowed Paths","description":"A Regular Expression that specifies the valid HTTP Paths that are allowed in the incoming URL Requests. If this value is specified and the path of the HTTP Requests does not match this Regular Expression, the Processor will respond with a 404: NotFound","required":false,"sensitive":false,"dynamic":false,"supportsEl":false},"Default URL Character Set":{"name":"Default URL Character Set","displayName":"Default URL Character Set","description":"The character set to use for decoding URL parameters if the HTTP Request does not supply one","defaultValue":"UTF-8","required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow GET":{"name":"Allow GET","displayName":"Allow GET","description":"Allow HTTP GET Method","defaultValue":"true","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow POST":{"name":"Allow POST","displayName":"Allow POST","description":"Allow HTTP POST Method","defaultValue":"true","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow PUT":{"name":"Allow PUT","displayName":"Allow PUT","description":"Allow HTTP PUT Method","defaultValue":"true","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow DELETE":{"name":"Allow DELETE","displayName":"Allow DELETE","description":"Allow HTTP DELETE Method","defaultValue":"true","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow HEAD":{"name":"Allow HEAD","displayName":"Allow HEAD","description":"Allow HTTP HEAD Method","defaultValue":"false","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow OPTIONS":{"name":"Allow OPTIONS","displayName":"Allow OPTIONS","description":"Allow HTTP OPTIONS Method","defaultValue":"false","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Additional HTTP Methods":{"name":"Additional HTTP Methods","displayName":"Additional HTTP Methods","description":"A comma-separated list of non-standard HTTP Methods that should be allowed","required":false,"sensitive":false,"dynamic":false,"supportsEl":false},"Client Authentication":{"name":"Client Authentication","displayName":"Client Authentication","description":"Specifies whether or not the Processor should authenticate clients. This value is ignored if the <SSL Context Service> Property is not specified or the SSL Context provided uses only a KeyStore and not a TrustStore.","defaultValue":"No Authentication","allowableValues":[{"allowableValue":{"displayName":"No Authentication","value":"No Authentication","description":"Processor will not authenticate clients. Anyone can communicate with this Processor anonymously"},"canRead":true},{"allowableValue":{"displayName":"Want Authentication","value":"Want Authentication","description":"Processor will try to verify the client but if unable to verify will allow the client to communicate anonymously"},"canRead":true},{"allowableValue":{"displayName":"Need Authentication","value":"Need Authentication","description":"Processor will reject communications from any client unless the client provides a certificate that is trusted by the TrustStorespecified in the SSL Context Service"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"container-queue-size":{"name":"container-queue-size","displayName":"Container Queue Size","description":"The size of the queue for Http Request Containers","defaultValue":"50","required":true,"sensitive":false,"dynamic":false,"supportsEl":false}},"validationErrors":["'HTTP Context Map' validated against 'StandardHttpContextMap' is invalid because Controller Service StandardHttpContextMap[id=fbec5165-015a-1000-ef40-26bc04ec2b63] is disabled"],"referenceType":"Processor","activeThreadCount":0}},{"revision":{"version":0,"lastModifier":"anonymous"},"id":"fbec516d-015a-1000-3273-3d36a22c0501","permissions":{"canRead":true,"canWrite":true},"component":{"groupId":"fc7d4a17-015a-1000-7731-9659aaa9b098","id":"fbec516d-015a-1000-3273-3d36a22c0501","name":"HandleHttpResponse","type":"HandleHttpResponse","state":"STOPPED","properties":{"HTTP Status Code":"${invokehttp.status.code:replaceNull('200')}","HTTP Context Map":"fbec5165-015a-1000-ef40-26bc04ec2b63"},"descriptors":{"HTTP Status Code":{"name":"HTTP Status Code","displayName":"HTTP Status Code","description":"The HTTP Status Code to use when responding to the HTTP Request. See Section 10 of RFC 2616 for more information.","required":true,"sensitive":false,"dynamic":false,"supportsEl":true},"HTTP Context Map":{"name":"HTTP Context Map","displayName":"HTTP Context Map","description":"The HTTP Context Map Controller Service to use for caching the HTTP Request Information","allowableValues":[{"allowableValue":{"displayName":"StandardHttpContextMap","value":"f6aa99d0-0159-1000-d428-5edef0de643e"},"canRead":true},{"allowableValue":{"displayName":"StandardHttpContextMap","value":"fbec5165-015a-1000-ef40-26bc04ec2b63"},"canRead":true},{"allowableValue":{"displayName":"StandardHttpContextMap","value":"fc7d8d0b-015a-1000-e0f4-d79e69229742"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false,"identifiesControllerService":"org.apache.nifi.http.HttpContextMap","identifiesControllerServiceBundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}}},"validationErrors":["'HTTP Context Map' validated against 'StandardHttpContextMap' is invalid because Controller Service StandardHttpContextMap[id=fbec5165-015a-1000-ef40-26bc04ec2b63] is disabled"],"referenceType":"Processor","activeThreadCount":0}},{"revision":{"version":0,"lastModifier":"anonymous"},"id":"fc7c07df-015a-1000-31cb-383c9f986aa6","permissions":{"canRead":true,"canWrite":true},"component":{"groupId":"fc7d4a17-015a-1000-7731-9659aaa9b098","id":"fc7c07df-015a-1000-31cb-383c9f986aa6","name":"HandleHttpResponse","type":"HandleHttpResponse","state":"STOPPED","properties":{"HTTP Status Code":"200","HTTP Context Map":"fbec5165-015a-1000-ef40-26bc04ec2b63"},"descriptors":{"HTTP Status Code":{"name":"HTTP Status Code","displayName":"HTTP Status Code","description":"The HTTP Status Code to use when responding to the HTTP Request. See Section 10 of RFC 2616 for more information.","required":true,"sensitive":false,"dynamic":false,"supportsEl":true},"HTTP Context Map":{"name":"HTTP Context Map","displayName":"HTTP Context Map","description":"The HTTP Context Map Controller Service to use for caching the HTTP Request Information","allowableValues":[{"allowableValue":{"displayName":"StandardHttpContextMap","value":"f6aa99d0-0159-1000-d428-5edef0de643e"},"canRead":true},{"allowableValue":{"displayName":"StandardHttpContextMap","value":"fbec5165-015a-1000-ef40-26bc04ec2b63"},"canRead":true},{"allowableValue":{"displayName":"StandardHttpContextMap","value":"fc7d8d0b-015a-1000-e0f4-d79e69229742"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false,"identifiesControllerService":"org.apache.nifi.http.HttpContextMap","identifiesControllerServiceBundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}}},"validationErrors":["'HTTP Context Map' validated against 'StandardHttpContextMap' is invalid because Controller Service StandardHttpContextMap[id=fbec5165-015a-1000-ef40-26bc04ec2b63] is disabled"],"referenceType":"Processor","activeThreadCount":0}}],"extensionMissing":false}},{"revision":{"version":0},"id":"f6aa99d0-0159-1000-d428-5edef0de643e","uri":"http://localhost:8080/nifi-api/controller-services/f6aa99d0-0159-1000-d428-5edef0de643e","permissions":{"canRead":true,"canWrite":true},"bulletins":[],"component":{"id":"f6aa99d0-0159-1000-d428-5edef0de643e","parentGroupId":"aa246331-015a-1000-fac3-b72f7046408b","name":"StandardHttpContextMap","type":"org.apache.nifi.http.StandardHttpContextMap","bundle":{"group":"org.apache.nifi","artifact":"nifi-http-context-map-nar","version":"1.4.0-SNAPSHOT"},"controllerServiceApis":[{"type":"org.apache.nifi.http.HttpContextMap","bundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}}],"comments":"","state":"DISABLED","persistsState":false,"restricted":false,"deprecated":false,"multipleVersionsAvailable":false,"properties":{"Maximum Outstanding Requests":"5000","Request Expiration":"1 min"},"descriptors":{"Maximum Outstanding Requests":{"name":"Maximum Outstanding Requests","displayName":"Maximum Outstanding Requests","description":"The maximum number of HTTP requests that can be outstanding at any one time. Any attempt to register an additional HTTP Request will cause an error","defaultValue":"5000","required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Request Expiration":{"name":"Request Expiration","displayName":"Request Expiration","description":"Specifies how long an HTTP Request should be left unanswered before being evicted from the cache and being responded to with a Service Unavailable status code","defaultValue":"1 min","required":true,"sensitive":false,"dynamic":false,"supportsEl":false}},"referencingComponents":[{"revision":{"version":0,"lastModifier":"anonymous"},"id":"f6a768c2-0159-1000-99a8-009ed9ec4783","permissions":{"canRead":true,"canWrite":true},"component":{"groupId":"fbec3833-015a-1000-ae7f-9ff2391f7f7b","id":"f6a768c2-0159-1000-99a8-009ed9ec4783","name":"HandleHttpResponse","type":"HandleHttpResponse","state":"STOPPED","properties":{"HTTP Status Code":"${invokehttp.status.code}","HTTP Context Map":"f6aa99d0-0159-1000-d428-5edef0de643e"},"descriptors":{"HTTP Status Code":{"name":"HTTP Status Code","displayName":"HTTP Status Code","description":"The HTTP Status Code to use when responding to the HTTP Request. See Section 10 of RFC 2616 for more information.","required":true,"sensitive":false,"dynamic":false,"supportsEl":true},"HTTP Context Map":{"name":"HTTP Context Map","displayName":"HTTP Context Map","description":"The HTTP Context Map Controller Service to use for caching the HTTP Request Information","allowableValues":[{"allowableValue":{"displayName":"StandardHttpContextMap","value":"f6aa99d0-0159-1000-d428-5edef0de643e"},"canRead":true},{"allowableValue":{"displayName":"StandardHttpContextMap","value":"fbec5165-015a-1000-ef40-26bc04ec2b63"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false,"identifiesControllerService":"org.apache.nifi.http.HttpContextMap","identifiesControllerServiceBundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}}},"validationErrors":["'HTTP Context Map' validated against 'StandardHttpContextMap' is invalid because Controller Service StandardHttpContextMap[id=f6aa99d0-0159-1000-d428-5edef0de643e] is disabled"],"referenceType":"Processor","activeThreadCount":0}},{"revision":{"version":0,"lastModifier":"anonymous"},"id":"f6badf53-0159-1000-33cb-6ded4fad66f9","permissions":{"canRead":true,"canWrite":true},"component":{"groupId":"fbec3833-015a-1000-ae7f-9ff2391f7f7b","id":"f6badf53-0159-1000-33cb-6ded4fad66f9","name":"HandleHttpResponse","type":"HandleHttpResponse","state":"STOPPED","properties":{"HTTP Status Code":"200","HTTP Context Map":"f6aa99d0-0159-1000-d428-5edef0de643e"},"descriptors":{"HTTP Status Code":{"name":"HTTP Status Code","displayName":"HTTP Status Code","description":"The HTTP Status Code to use when responding to the HTTP Request. See Section 10 of RFC 2616 for more information.","required":true,"sensitive":false,"dynamic":false,"supportsEl":true},"HTTP Context Map":{"name":"HTTP Context Map","displayName":"HTTP Context Map","description":"The HTTP Context Map Controller Service to use for caching the HTTP Request Information","allowableValues":[{"allowableValue":{"displayName":"StandardHttpContextMap","value":"f6aa99d0-0159-1000-d428-5edef0de643e"},"canRead":true},{"allowableValue":{"displayName":"StandardHttpContextMap","value":"fbec5165-015a-1000-ef40-26bc04ec2b63"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false,"identifiesControllerService":"org.apache.nifi.http.HttpContextMap","identifiesControllerServiceBundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}}},"validationErrors":["'HTTP Context Map' validated against 'StandardHttpContextMap' is invalid because Controller Service StandardHttpContextMap[id=f6aa99d0-0159-1000-d428-5edef0de643e] is disabled"],"referenceType":"Processor","activeThreadCount":0}},{"revision":{"version":0,"lastModifier":"anonymous"},"id":"f6a4d400-0159-1000-b6cd-91781ea84d73","permissions":{"canRead":true,"canWrite":true},"component":{"groupId":"fbec3833-015a-1000-ae7f-9ff2391f7f7b","id":"f6a4d400-0159-1000-b6cd-91781ea84d73","name":"HandleHttpRequest","type":"HandleHttpRequest","state":"STOPPED","properties":{"Listening Port":"9999","Hostname":"localhost","SSL Context Service":null,"HTTP Context Map":"f6aa99d0-0159-1000-d428-5edef0de643e","Allowed Paths":null,"Default URL Character Set":"UTF-8","Allow GET":"true","Allow POST":"true","Allow PUT":"true","Allow DELETE":"true","Allow HEAD":"false","Allow OPTIONS":"false","Additional HTTP Methods":null,"Client Authentication":"No Authentication","container-queue-size":"50"},"descriptors":{"Listening Port":{"name":"Listening Port","displayName":"Listening Port","description":"The Port to listen on for incoming HTTP requests","defaultValue":"80","required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Hostname":{"name":"Hostname","displayName":"Hostname","description":"The Hostname to bind to. If not specified, will bind to all hosts","required":false,"sensitive":false,"dynamic":false,"supportsEl":false},"SSL Context Service":{"name":"SSL Context Service","displayName":"SSL Context Service","description":"The SSL Context Service to use in order to secure the server. If specified, the server will accept only HTTPS requests; otherwise, the server will accept only HTTP requests","allowableValues":[],"required":false,"sensitive":false,"dynamic":false,"supportsEl":false,"identifiesControllerService":"org.apache.nifi.ssl.RestrictedSSLContextService","identifiesControllerServiceBundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}},"HTTP Context Map":{"name":"HTTP Context Map","displayName":"HTTP Context Map","description":"The HTTP Context Map Controller Service to use for caching the HTTP Request Information","allowableValues":[{"allowableValue":{"displayName":"StandardHttpContextMap","value":"f6aa99d0-0159-1000-d428-5edef0de643e"},"canRead":true},{"allowableValue":{"displayName":"StandardHttpContextMap","value":"fbec5165-015a-1000-ef40-26bc04ec2b63"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false,"identifiesControllerService":"org.apache.nifi.http.HttpContextMap","identifiesControllerServiceBundle":{"group":"org.apache.nifi","artifact":"nifi-standard-services-api-nar","version":"1.4.0-SNAPSHOT"}},"Allowed Paths":{"name":"Allowed Paths","displayName":"Allowed Paths","description":"A Regular Expression that specifies the valid HTTP Paths that are allowed in the incoming URL Requests. If this value is specified and the path of the HTTP Requests does not match this Regular Expression, the Processor will respond with a 404: NotFound","required":false,"sensitive":false,"dynamic":false,"supportsEl":false},"Default URL Character Set":{"name":"Default URL Character Set","displayName":"Default URL Character Set","description":"The character set to use for decoding URL parameters if the HTTP Request does not supply one","defaultValue":"UTF-8","required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow GET":{"name":"Allow GET","displayName":"Allow GET","description":"Allow HTTP GET Method","defaultValue":"true","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow POST":{"name":"Allow POST","displayName":"Allow POST","description":"Allow HTTP POST Method","defaultValue":"true","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow PUT":{"name":"Allow PUT","displayName":"Allow PUT","description":"Allow HTTP PUT Method","defaultValue":"true","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow DELETE":{"name":"Allow DELETE","displayName":"Allow DELETE","description":"Allow HTTP DELETE Method","defaultValue":"true","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow HEAD":{"name":"Allow HEAD","displayName":"Allow HEAD","description":"Allow HTTP HEAD Method","defaultValue":"false","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Allow OPTIONS":{"name":"Allow OPTIONS","displayName":"Allow OPTIONS","description":"Allow HTTP OPTIONS Method","defaultValue":"false","allowableValues":[{"allowableValue":{"displayName":"true","value":"true"},"canRead":true},{"allowableValue":{"displayName":"false","value":"false"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"Additional HTTP Methods":{"name":"Additional HTTP Methods","displayName":"Additional HTTP Methods","description":"A comma-separated list of non-standard HTTP Methods that should be allowed","required":false,"sensitive":false,"dynamic":false,"supportsEl":false},"Client Authentication":{"name":"Client Authentication","displayName":"Client Authentication","description":"Specifies whether or not the Processor should authenticate clients. This value is ignored if the <SSL Context Service> Property is not specified or the SSL Context provided uses only a KeyStore and not a TrustStore.","defaultValue":"No Authentication","allowableValues":[{"allowableValue":{"displayName":"No Authentication","value":"No Authentication","description":"Processor will not authenticate clients. Anyone can communicate with this Processor anonymously"},"canRead":true},{"allowableValue":{"displayName":"Want Authentication","value":"Want Authentication","description":"Processor will try to verify the client but if unable to verify will allow the client to communicate anonymously"},"canRead":true},{"allowableValue":{"displayName":"Need Authentication","value":"Need Authentication","description":"Processor will reject communications from any client unless the client provides a certificate that is trusted by the TrustStorespecified in the SSL Context Service"},"canRead":true}],"required":true,"sensitive":false,"dynamic":false,"supportsEl":false},"container-queue-size":{"name":"container-queue-size","displayName":"Container Queue Size","description":"The size of the queue for Http Request Containers","defaultValue":"50","required":true,"sensitive":false,"dynamic":false,"supportsEl":false}},"validationErrors":["'HTTP Context Map' validated against 'StandardHttpContextMap' is invalid because Controller Service StandardHttpContextMap[id=f6aa99d0-0159-1000-d428-5edef0de643e] is disabled"],"referenceType":"Processor","activeThreadCount":0}}],"extensionMissing":false}}]}
... View more
09-19-2017
09:49 AM
Hi @Onkar Pathak, Controller services are defined at process group level (except controller services used for reporting tasks). To get the list of controller services, you'd have to define on which process group you ant to perform the listing, then you can use the following endpoint: POST /process-groups/{id}/controller-services https://nifi.apache.org/docs/nifi-docs/rest-api/
... View more
09-19-2017
09:37 AM
You'd probably want to have a signal identifier using a unique flow file attribute (such as uuid). If you could provide more details around what you want to achieve, that'd be helpful.
... View more