Member since
06-09-2016
185
Posts
22
Kudos Received
5
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
2188 | 04-21-2017 07:57 AM | |
1365 | 04-18-2017 07:07 AM | |
3253 | 02-27-2017 05:41 AM | |
909 | 12-09-2016 11:05 AM | |
1271 | 11-24-2016 11:20 AM |
12-05-2016
08:58 AM
Hi @Andrew Grande I tried to run the reconfigure.groovy - however the search api can't get anything, I tried name, uuid Caught: groovyx.net.http.HttpResponseException: Not Found
groovyx.net.http.HttpResponseException: Not Found
at groovyx.net.http.RESTClient.defaultFailureHandler(RESTClient.java:263)
at groovyx.net.http.HTTPBuilder$1.handleResponse(HTTPBuilder.java:503)
at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:1070)
at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:1044)
at groovyx.net.http.HTTPBuilder.doRequest(HTTPBuilder.java:515)
... View more
12-05-2016
06:38 AM
@kkawamura I tried this but got - Message body is malformed. Unable to map into expected format. Also in GET resonse I don't see any "state" tag
... View more
12-05-2016
06:06 AM
Hi, I am able to start/stop processors using rest-api, can we do the same to process groups? The GET api doesn't show any status tag. What is the JSON we can POST to start/stop it? Thanks, Avijeet {
"revision": {
"version": 0
},
"id": "8619c3f4-0158-1000-a750-24884f23ea60",
"uri": "http://localhsot:8080/nifi-api/process-groups/8619c3f4-0158-1000-a750-24884f23ea60",
"position": {
"x": 0,
"y": 0
},
"permissions": {
"canRead": true,
"canWrite": true
},
"bulletins": [],
"component": {
"id": "8619c3f4-0158-1000-a750-24884f23ea60",
"position": {
"x": 0,
"y": 0
},
"name": "NiFi Flow",
"comments": "",
"runningCount": 0,
"stoppedCount": 7,
"invalidCount": 0,
"disabledCount": 0,
"activeRemotePortCount": 0,
"inactiveRemotePortCount": 0,
"inputPortCount": 0,
"outputPortCount": 0
},
"status": {
"id": "8619c3f4-0158-1000-a750-24884f23ea60",
"name": "NiFi Flow",
"statsLastRefreshed": "06:00:52 UTC",
"aggregateSnapshot": {
"id": "8619c3f4-0158-1000-a750-24884f23ea60",
"name": "NiFi Flow",
"flowFilesIn": 0,
"bytesIn": 0,
"input": "0 (0 bytes)",
"flowFilesQueued": 36,
"bytesQueued": 1536,
"queued": "36 (1.5 KB)",
"queuedCount": "36",
"queuedSize": "1.5 KB",
"bytesRead": 296384,
"read": "289.44 KB",
"bytesWritten": 209649,
"written": "204.74 KB",
"flowFilesOut": 0,
"bytesOut": 0,
"output": "0 (0 bytes)",
"flowFilesTransferred": 1519,
"bytesTransferred": 592128,
"transferred": "1,519 (578.25 KB)",
"bytesReceived": 92325,
"flowFilesReceived": 75,
"received": "75 (90.16 KB)",
"bytesSent": 0,
"flowFilesSent": 0,
"sent": "0 (0 bytes)",
"activeThreadCount": 0
}
},
"runningCount": 0,
"stoppedCount": 7,
"invalidCount": 0,
"disabledCount": 0,
"activeRemotePortCount": 0,
"inactiveRemotePortCount": 0,
"inputPortCount": 0,
"outputPortCount": 0
}
... View more
Labels:
- Labels:
-
Apache NiFi
12-02-2016
12:45 PM
Thanks @Greg Keys - I was under impression the we are extracting from attributes. Can you pls share any documentation which clearly explain the lifecycle of a Event/flowfile going through a dataflow and any best practices.
... View more
12-02-2016
11:05 AM
Hi @Andrew Grande is the nifi-api-deploy works fine for nifi-1.0.0? I was trying it got this error - can you pls suggest what's wrong. Thanks. 2016/12/02 10:57:45:199 UTC [DEBUG] BasicClientConnectionManager - Get connection for route {}->http://localhost:8080
2016/12/02 10:57:45:219 UTC [DEBUG] DefaultClientConnectionOperator - Connecting to localhost:8080
2016/12/02 10:57:45:249 UTC [DEBUG] RequestAddCookies - CookieSpec selected: best-match
2016/12/02 10:57:45:265 UTC [DEBUG] RequestAuthCache - Auth cache not set in the context
2016/12/02 10:57:45:265 UTC [DEBUG] RequestTargetAuthentication - Target auth state: UNCHALLENGED
2016/12/02 10:57:45:266 UTC [DEBUG] RequestProxyAuthentication - Proxy auth state: UNCHALLENGED
2016/12/02 10:57:45:266 UTC [DEBUG] DefaultHttpClient - Attempt 1 to execute request
2016/12/02 10:57:45:267 UTC [DEBUG] DefaultClientConnection - Sending request: GET /nifi-api/controller/process-groups/root/process-group-references HTTP/1.1
2016/12/02 10:57:45:267 UTC [DEBUG] wire - >> "GET /nifi-api/controller/process-groups/root/process-group-references HTTP/1.1[\r][\n]"
2016/12/02 10:57:45:269 UTC [DEBUG] wire - >> "Accept: */*[\r][\n]"
2016/12/02 10:57:45:269 UTC [DEBUG] wire - >> "Host: localhost:8080[\r][\n]"
2016/12/02 10:57:45:269 UTC [DEBUG] wire - >> "Connection: Keep-Alive[\r][\n]"
2016/12/02 10:57:45:269 UTC [DEBUG] wire - >> "[\r][\n]"
2016/12/02 10:57:45:269 UTC [DEBUG] headers - >> GET /nifi-api/controller/process-groups/root/process-group-references HTTP/1.1
2016/12/02 10:57:45:269 UTC [DEBUG] headers - >> Accept: */*
2016/12/02 10:57:45:269 UTC [DEBUG] headers - >> Host: localhost:8080
2016/12/02 10:57:45:269 UTC [DEBUG] headers - >> Connection: Keep-Alive
2016/12/02 10:57:45:271 UTC [DEBUG] wire - << "HTTP/1.1 404 Not Found[\r][\n]"
2016/12/02 10:57:45:273 UTC [ [ERROR] HTTP call failed. Status code: HTTP/1.1 404 Not Found: The specified resource could not be found.
Caught: java.lang.AssertionError: Terminated script execution. Expression: null
java.lang.AssertionError: Terminated script execution. Expression: null
... View more
12-02-2016
09:26 AM
Hi @Andrew Grande I am trying to download a template using rest api - where do I get the id of the template /templates/{id}/download I have stored the template with a name. Thanks, Avijeet
... View more
12-02-2016
05:25 AM
Thanks @Bryan Bende, makes sense. quick follow up. So can we say we can have one cluster (say 5 node) - we can put the nifi + KAFKA (one broker in each node) in same nodes, I believe HDF cluster would be doing same way, so each node would have a nifi instance + KAFKA broker + storm supervisor. Also as NIFI doesn't do replication, it would not be disk crash proof. please correct if wrong.
... View more
12-01-2016
12:17 PM
Hi @Bryan Bende Great Artcile! I have one question - KAFKA is a disk-bound distributed system I believe NIFI as well disk bound as it acts a reliable-buffer similar to KAFKA + all the productivity ui based Is there a strong reason to go for both NIFI + KAFKA what are the reliability features of NIFI, is it machine/disk crash proof? The persistent/replay features of KAFKA are mostly not there in NIFI? pls correct me if wrong.
... View more
12-01-2016
10:46 AM
Hi, Is it possible to save a nifi dataflow to an existing template, instead of creating new templates everytime. Thanks, Avijeet
... View more
Labels:
- Labels:
-
Apache NiFi
11-30-2016
08:56 AM
Hi Peter, Thanks, let me try to see is if i can start a template/process group using rest-api without loading in UI.
... View more