Member since
07-19-2018
613
Posts
101
Kudos Received
117
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 5093 | 01-11-2021 05:54 AM | |
| 3421 | 01-11-2021 05:52 AM | |
| 8789 | 01-08-2021 05:23 AM | |
| 8384 | 01-04-2021 04:08 AM | |
| 36686 | 12-18-2020 05:42 AM |
01-20-2020
05:55 AM
1 Kudo
@VijaySankar In a recent Use Case, I had to connect invokeHttp to an API (https) to get an S3 bucket URL and then to Amazon S3 (https) to download the file. Each InvokeHTTP required its own SSL Context Service and for each I complete the following: Obtain the public SSL certificate from the end point. I use curl, or standard browser to download the cert. Use the cert to make a truststore (JKS) file. Put this truststore on all my NiFi nodes, owned nifi:nifi Put the trustore path, type, and password in the SSL Context Service. Enable Context Service, and test InvokeHTTP Hope this helps get you going...
... View more
01-15-2020
05:01 AM
1 Kudo
I am going to test it here myself shortly. I have a use case where we are inserting ISO-8601 into Elastic where data ultimately also goes to exernal csv table (wi thout the timestamp). I should be able to quickly validate what is required for a working example. I suspect you are having issues with the after ss parts matching the serde syntax.
... View more
01-15-2020
04:37 AM
According to this previous accepted solution: ALTER TABLE table SET SERDEPROPERTIES ("timestamp.formats"="yyyy-MM-dd'T'HH:mm:ss");
Works only in case of Textformat,CSV format tables.
If you are having other format table like orc..etc then set serde properties are not got to be working.
... View more
01-13-2020
04:23 AM
I believe the best thing to do is jump right in. Start working with Cloudera Products. Complete some demos, join in online training, study documentation, and start creating experience. As an example here are a few things that Solution Architects work on at Cloudera: Install CDH or previous products: CDM, HDP, & HDF. Hadoop Yarn & Map Reduce Spark Kafka Hive & Hive LLAP NiFi, NiFi Registry, & Schema Registry Security (SSL, Encryption, etc) Active Directory, LDAP, and Ranger Other Components: Hbase, Solar, Impala, Zeppelin Cloudera Course List: https://ondemand.cloudera.com/courses Free CDP Essentials: https://www.cloudera.com/about/training/courses/cloudera-essentials-for-cdp.html (free)
... View more
01-12-2020
06:58 AM
@Chada Can you share more details regarding any specific errors? This post may have the solution you are looking for: https://community.cloudera.com/t5/Support-Questions/Getting-Unable-to-obtain-listing-of-buckets-org-apache-nifi/td-p/227855
... View more
01-12-2020
06:52 AM
@ashishtiw26 Can you show us the configuration of the CSVReader Controller Service, the PutDatabaseRecord Processor, and sample of the contents of a FlowFile before PutDatabaseRecord. Contributors need to see as much information as possible in order to trouble shoot specific error messages.
... View more
01-12-2020
05:44 AM
2 Kudos
@murali2425 You could build a nifi flow that could “copy” files to guthub. This would need to be done by creating a custom processor or maybe even just ExecuteScript to run a custom python script. Either route you take you would need to make sure that all nifi nodes are setup with permissions to write to the github repo. Then inside of your custom processor or script you would execute the required git commands to commit (“copy”) the file(s).
... View more
01-10-2020
05:33 AM
2 Kudos
@VijaySankar can you accept my answer (remove localhost) as the solution?
... View more
01-10-2020
05:05 AM
Ahh I did not pay attention to that in the original screen shot, just tried to offer the syntax for the json parsing. Glad you got it to work! Isn't learning NiFi fun? I love it.
... View more
01-09-2020
01:37 PM
In the routeonattribute proc you use just the ${attribute:equals(‘value’)} that you parsed from evaluatejson proc. Evaluatejson: attribute = $.HR.finance.name RouteOnAttribute ${attribute:equals(‘Murali’)}
... View more