Re: Edit QueryCassandra processor using REST API.

2018-11-14 Thread Koji Kawamura
Hi Dnyaneshwar, You can terminate remaining thread forcefully by sending a DELETE request to /processors/{id}/threads. https://nifi.apache.org/docs/nifi-docs/rest-api/index.html Thanks, Koji On Thu, Nov 15, 2018 at 4:14 PM Dnyaneshwar Pawar wrote: > > Hi > > We are trying to edit the

RE: NiFi 1.7.1 remote group not connecting when added through restful api until nifi restarted

2018-11-14 Thread christophe.monnet
Hi William My experience with using the REST API to create RPG is that you must wait "some time" before the port becomes available. A restart is not needed though. My workaround is to repeatedly call GET on the RPG until the port becomes available. It typically takes more than 10 seconds on a 5

Edit QueryCassandra processor using REST API.

2018-11-14 Thread Dnyaneshwar Pawar
Hi We are trying to edit the QueryCassandra processor using REST API, this needs processor to be stopped programmatically and start post changes done. In this processes, initially we were getting issue of processor taking time to stop. We added wait time of 10 sec and that worked. However,

Re: NiFi 1.7.1 remote group not connecting when added through restful api until nifi restarted

2018-11-14 Thread Koji Kawamura
Hello William, > fails to connect to the existing input port until I do a restart of NiFi Is there any error message when it fails? Connection refused? It should not require a NiFi restart to establish connection. Thanks, Koji On Thu, Nov 15, 2018 at 1:38 AM William Gosse wrote: > > I'm

Re: CaptureChangeMySQL - throwing Binlog connector communications failure

2018-11-14 Thread Koji Kawamura
> Sometimes it fails (I ensure that the state is cleared), and then I have to > restart it with latest binlog position. Does it fail with the same error message? com.github.shyiko.mysql.binlog.network.ServerException: could not find next log; the first event 'bin_8101.01' at 142923964, the

RE: Parsing a template to identify processor names

2018-11-14 Thread Vitaly Krivoy
This is very good. So now there two ways to accomplish the objective!  -Original Message- From: Koji Kawamura Sent: Tuesday, November 13, 2018 7:50 PM To: users@nifi.apache.org Subject: Re: Parsing a template to identify processor names Hello, I'm not sure if this is what you're

RE: [Non-DoD Source] Re: rotating servers

2018-11-14 Thread Cassidy, Thomas G (Tom) JR CTR USARMY MEDCOM JMLFDC (USA)
Joe thanks for the question. I checked and it was written inhouse a while back so you're right it is something we need to look at. Thanks -- tc Tom Cassidy -Original Message- From: Joe Witt [mailto:joe.w...@gmail.com] Sent: Wednesday, November 14, 2018 12:10 PM To:

Re: rotating servers

2018-11-14 Thread Joe Witt
Tom, Just want to make sure I'm following here but the custom Controller Service you reference is where this logic lives/should live. Right? If that is the case then you'll want to focus on improving the behavior of the controller service to switch over. If that is not the case can you share

rotating servers

2018-11-14 Thread Cassidy, Thomas G (Tom) JR CTR USARMY MEDCOM JMLFDC (USA)
We have created a controller service for JBOSS-BT-JNDIService. The "java.naming.provider.url (target host and port)" has been configured to use 3 different JBOSS servers. The problem is that NiFi seems to always use the first server and only rarely moves onto the 2nd or 3rd when the first is

NiFi 1.7.1 remote group not connecting when added through restful api until nifi restarted

2018-11-14 Thread William Gosse
I'm using NiFi's restful api to create a process group from a template that contains a file folder listener and a remote group. I also have an existing input port going to a process group that has the file fetch and everything else for processing the file that was fetched. This is not added by

Re: Getting a timestamp for today at midnight?

2018-11-14 Thread Mark Payne
You should be able to do something like: ${now():divide( 8640 ):multiply( 8640)} I.e., use integer division to divide by number of milliseconds in a day, which gives you the number of days since epoch. Then multiply by 86,400,000 again to convert from days back to milliseconds. While

Getting a timestamp for today at midnight?

2018-11-14 Thread l vic
I have to retrieve "today's" records in ExecuteSQL, eg. with the query using timestamp "ts" column in table where ts type is "epoch" time as long integer : select * from mytable where ts >= midnight-timestamp-value Any idea how i can use "now()" function to get today's timestamp value at midnight?

Re: CaptureChangeMySQL - throwing Binlog connector communications failure

2018-11-14 Thread Anand Dev
When I restart the Processor from the binlog pos where it stopped, not everytime it starts successfully. Sometimes it fails (I ensure that the state is cleared), and then I have to restart it with latest binlog position. Is there any thing apart from state to be taken care while restarting the