processGroupId URL

Hello community, I'm trying to write a log when errors occur in my flow, and I want to include the fully qualified URL to the location within my flow where the error occurred. I know the component ID is an attribute I can use, but I also need the processGroupId where the component is located

Re: PutDatabaseRecord won't put Timestamp field

Matt were you using 1.6? On Thu, Apr 5, 2018 at 3:56 PM Mike Thomsen wrote: > 1.5 > > Thanks, > > Mike > > On Thu, Apr 5, 2018 at 3:40 PM, Matt Burgess wrote: > >> Mike, >> >> I can't reproduce this, I use the same DDL and Avro schema, with data >>

PUT/flow/process-groups/{id} API

I am trying to use PUT/flow/process-groups/{id} to start a processing group from a Java program, but nothing is happening. I set state RUNNING in ScheduleComponentsEntity and when an API call returns it shows the state in the returned object as RUNNING. But I see on the canvas that the group

Re: NiFi 1.6

dan It is presently working through the release candidate vote process. As it stands now it could be out tomorrow. Please do help by reviewing the rc if you have time. If you have questions on how to do it just let us know and we can help. thanks joe On Thu, Apr 5, 2018, 1:46 PM dan young

NiFi 1.6

any updates on when 1.6 is going to drop? dano

Re: PutDatabaseRecord won't put Timestamp field

1.5 Thanks, Mike On Thu, Apr 5, 2018 at 3:40 PM, Matt Burgess wrote: > Mike, > > I can't reproduce this, I use the same DDL and Avro schema, with data > coming in from the SiteToSiteProvenanceReportingTask and going to > Postgres, and it works fine. What version of NiFi

Re: PutDatabaseRecord won't put Timestamp field

Mike, I can't reproduce this, I use the same DDL and Avro schema, with data coming in from the SiteToSiteProvenanceReportingTask and going to Postgres, and it works fine. What version of NiFi are you using? Regards, Matt On Thu, Apr 5, 2018 at 3:05 PM, Mike Thomsen

PutDatabaseRecord won't put Timestamp field

Found these errors in the Docker logs: postgres_1 | 2018-04-05 18:33:22.183 UTC [51] ERROR: column "timestamp_field" is of type timestamp without time zone but expression is of type bigint at character 282 postgres_1 | 2018-04-05 18:33:22.183 UTC [51] HINT: You will need to rewrite

Re: Cluster coordinator does not update cluster subdomain when new node states up

Did you rebuild all your ZooKeeper servers too, or just rebuilt NiFi servers point at the same existing ZooKeeper? On Thu, Apr 5, 2018 at 2:16 PM, Andy LoPresto wrote: > I suppose it could be a weird routing issue with your DNS settings or a > modified /etc/hosts file? Can

Re: Cluster coordinator does not update cluster subdomain when new node states up

I suppose it could be a weird routing issue with your DNS settings or a modified /etc/hosts file? Can you flush the DNS cache and try again? You can also grep for that address across all configuration files in the conf directory to see if it’s persisted anywhere. If you grep from a directory up

Re: Cluster coordinator does not update cluster subdomain when new node states up

I was not able to find any place where that previous node is in the properties files. I rebuilt the cluster from scratch using my Ansible playbook so I updated all the areas there and reconfigured brand new servers. I had this problem once before previously and just bringing up brand new

Re: Cluster coordinator does not update cluster subdomain when new node states up

Hi Scott, Can you check the contents of your nifi.properties (specifically the nifi.cluster.* and nifi.zookeeper.* sections) as well as the conf/zookeeper.properties files on each node in the cluster to see if one still has the old address? Andy LoPresto alopre...@apache.org

Cluster coordinator does not update cluster subdomain when new node states up

I had to change the subdomain of my cluster nodes. The cluster node names are nifi-{#}.internal.dev.{redacted}.com. Looking at my log below it still believes there is a cluster coordinator is found at nifi-2.dev.{redacted}.com. o.a.n.c.c.node.NodeClusterCoordinator Failed to determine which

Re: Escape Single Quote

that was it. Thank you On Thu, Apr 5, 2018 at 11:12 AM, James Wing wrote: > I believe you need something like > > ${my_forcast:replace("'","\\'")} > > Using two backslashes \\. The backslash is also used as an escape > character in the expression language string, so you need

Re: Escape Single Quote

I believe you need something like ${my_forcast:replace("'","\\'")} Using two backslashes \\. The backslash is also used as an escape character in the expression language string, so you need two consecutive backslashes to make one literal backslash in the output. On Thu, Apr 5, 2018 at 7:31 AM,

Re: MiNiFi C++ and Tensorflow future plans?

-BEGIN PGP SIGNED MESSAGE- Hash: SHA1 Iyán, > I was wondering what is the roadmap and future plans of MiNiFi C++ agent > regarding Tensorflow processors. With the three that are mentioned in the > article it is possible to classify images on edge but I would like to know if > other

Escape Single Quote

Need to escape single quote for PutSql. 'Today's forecast ...' by a backslash: 'Today\'s forecast ...', How can this be done using ReplaceText? ${my_forcast:replace("'","\'")} does not work.

MiNiFi C++ and Tensorflow future plans?

Hi, I am considering using Hortonworks HDF to try NiFi and MiNiFi C++ agent in order to do some tests. After reading these links: https://es.hortonworks.com/blog/hortonworks-dataflow-hdf-3-1-blog-series-part-6-introducing-apache-minifi-c-agent