Member since
06-26-2015
515
Posts
137
Kudos Received
114
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
2073 | 09-20-2022 03:33 PM | |
5710 | 09-19-2022 04:47 PM | |
3085 | 09-11-2022 05:01 PM | |
3426 | 09-06-2022 02:23 PM | |
5407 | 09-06-2022 04:30 AM |
08-14-2022
03:58 PM
1 Kudo
@totokogure , The EvaluateJsonPath that you added is extracting the $.hits array and storing it as an attribute. The next processor (SplitJson), does not even use that attribute, though. It extracts $.hits again from the flowfile content. The EvaluateJsonPath in this flow should be unnecessary. If you connected InvokeHTTP to SplitJson, things should work correctly. Cheers, André
... View more
08-14-2022
03:51 PM
1 Kudo
Hi @LorencH , I'm of the opinion that if security is a concern (as it should be for any deployment) you should never rely on the permissions that come within the tarball. Your deployment procedure, automated or not, should always extract the files and explicitly "chown" and "chmod" the appropriate files to set the desired ownership and permissions. I don't know of the reasons to eliminate the tarball, though. Cheers, André
... View more
08-11-2022
10:40 PM
@totokogure , I tested this on the same version of NiFi that you're using (1.17.0) and it worked fine for me. The sample content that you provided was split in 2 flowfiles. Cheers, André
... View more
08-11-2022
03:58 AM
@rafy Try this: ${DATE_TIME:toDate('yyyy-MM-dd HH:mm:ss.SSSSSSSSS'):format('dd/MM/yyyy HH:mm:ss.SSSSSS')} Cheers, André
... View more
08-11-2022
03:48 AM
1 Kudo
@romi , You can try to connect to some NiFi API endpoint. If it succeed, it's an indication that the service is up. For example: $ curl -k "https://mynifi:8443/nifi-api/access"
{"accessStatus":{"status":"UNKNOWN","message":"Access Unknown: Certificate and Token not found."}} If the command above returned anything different, you could send an alert. Cheers, André
... View more
08-10-2022
01:25 AM
Then the service will be unavailable until you recover at least one of them.
... View more
08-09-2022
02:52 PM
@noekmc , How are you restarting Cloudera Manager? This restart must be done from the command line, on the CM host: sudo systemctl restart cloudera-scm-server Cheers, André
... View more
08-09-2022
02:38 PM
@Big-dAta , A quorum in a ZooKeeper ensemble is a group of servers with more than half of the total number of servers in the ensemble. So for an ensemble of 5 servers, the quorum is 3 servers. As long as there are 3 servers available an election can always be carried out. So, in your example, the 4 remaining servers will talk to each other and decide who will be the new leader. Cheers, André
... View more
08-08-2022
11:25 PM
@ho_ddeok , Hive 1 is a very old version and and equi-join was probably the only option available back then. As @nramanaiah mentioned, you should consider upgrading to the latest version, where this statement works. Nevertheless, you can try the following alternative query. I'm not sure if it works, though, since I don't have a Hive 1 environment to test this: select *
from A cross join B
where A.c1 like B.c2; Cheers, André
... View more
08-08-2022
07:12 PM
1 Kudo
@RB764 , Ok, I see. In the case of running JS code on the browser client, it makes sense to see the errors that you are seeing. That's exactly what CORS restrictions are designed for. Are you loading this script from a file locally on your computer or is this part from a web application that you have running on a server? If this is local to your computer, I would recommend that you use some other language to interact with NiFi, since running this locally on a browser has limitations. In Python, for example, you can use the nipyapi module, which makes it really easy to interact with the NiFi API: from nipyapi import config, security
from nipyapi.nifi.apis.flow_api import FlowApi
config.nifi_config.host = 'https://<<server host:port>>/nifi-api'
security.set_service_ssl_context(service='nifi', ca_file='<</path/to/truststore.pem>>')
security.service_login(service='nifi', username='<<user>>', password='<<pwd>>')
api = FlowApi()
summary = api.get_cluster_summary() If what you are trying to do is part of a web application, the interaction between application and NiFi should happen on the server side instead of the browser. This would also eliminate any sort of CORS issues. Cheers, André
... View more