Member since
06-13-2016
30
Posts
20
Kudos Received
5
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
9786 | 12-26-2016 08:14 PM | |
3300 | 12-24-2016 05:22 PM | |
2324 | 12-19-2016 02:01 AM | |
4067 | 12-05-2016 01:52 PM | |
6829 | 09-08-2016 09:00 PM |
07-08-2017
06:25 AM
It worked for me to change the database to mysql.
1.you need to create user and databases named 'superset' using mysql shell
GRANT ALL PRIVILEGES ON *.* TO 'superset'@'%' IDENTIFIED BY '*****' WITH GRANT OPTION;
create database superset; 2. change the config for Druid , set Mysql's hostname port user password .etc 3. start the druid, and it worked!
... View more
02-23-2017
12:31 AM
you can create an email alias with many accounts associated to it.
... View more
12-26-2016
08:14 PM
4 Kudos
@David Parkins Your best option for doing this is going to be using the
UpdateAttribute processor and then using a little NiFi Expression Language to
append the date onto your file. From
there you should be able to configure. I
created a sample flow and used the following config and achieved the following
results: /var/log/log1.log New filename: log1.log.2016-12-26 15:10:25.966Z This is the config on the updateAttribute processor: This is just a sample, you could do a lot better using append/prepend with NiFi Expression Language. There is more info here: https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html
... View more
12-26-2016
06:43 PM
1 Kudo
@mayki wogno user defined arguments aren't really sent to ExecuteScript. If the value of the `filename` attribute is needed, it can be retrieved from the flow file itself. Below is an example of how to retrieve the `filename` attribute, update the attribute, and send the flow file to a `success` relationship. flowFile = session.get()
if (flowFile != None):
filename = flowFile.getAttribute("filename")
flowFile = session.putAttribute(flowFile, "filename", filename + "new_name")
session.transfer(flowFile, REL_SUCCESS)
For an example that is a little more in depth, you can download a template from this gist. For a deeper look into developing with NiFi, please see the developer's guide.
... View more
12-29-2016
08:41 AM
@Matt Burgess If the query returns too many rows in QueryDatabaseTable, can you set Max Rows Per Flow File and Fetch Size to something like 10000? -> yes, I have do that, but it doesn't work... I have 30 000 000 + data in postgreSQL so an exception of OutOfMemory is normal. I'm looking forward to your answer for PutElasticSearchHTTP.
... View more
12-19-2016
12:12 PM
@Kumar, as tests by me and @Devin Pinkston show, it is the actual file content that you need to look at (not the UI). Thus ... no fears of the processor adding a new line.
... View more
12-05-2016
03:20 PM
thankyou @Matt Burgess I will use the Http processors in the meantime then!
... View more
09-08-2016
09:32 PM
3 Kudos
Thanks for the answer. What you posted didn't work, but I did play with and eventually got it. What I had to do was have an UpdateAttribute processor before my InvokeHTTP that sets an attribute called "Content-Type", then in InvokeHTTP, set "attributes to send" to "Content-Type" and it worked. Thanks!
... View more
06-14-2017
02:23 PM
I confirmed this to be a bug in ConvertJSONToSQL, I have written up NIFI-4071, please see the Jira for details.
... View more