Member since
11-16-2015
905
Posts
666
Kudos Received
249
Solutions
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 513 | 09-30-2025 05:23 AM | |
| 849 | 06-26-2025 01:21 PM | |
| 761 | 06-19-2025 02:48 PM | |
| 937 | 05-30-2025 01:53 PM | |
| 11699 | 02-22-2024 12:38 PM |
11-01-2018
08:28 PM
Since your CSV headers match the column names exactly, try setting Translate Field Names to false.
... View more
10-30-2018
03:45 PM
1 Kudo
Try the following chain spec (it uses Modify-overwrite instead of Shift): [
{
"operation": "modify-overwrite-beta",
"spec": {
"effectiveStart": "=toString",
"effectiveEnd": "=toString"
}
}
] That will preserve all other fields, but change the values of effectiveStart/End to strings
... View more
10-30-2018
03:43 PM
Do you need the numbers as-is into strings, or a formatted timestamp string, or something else?
... View more
10-30-2018
01:55 PM
If you're using a DistributedMapCacheServer, you can set a "Persistence Directory" and it will store the cache to disk, so it will be available on restart. DistributedMapCacheServers are started on each node in a cluster, but your DistributedMapCacheClientService provides the hostname and port to only one of them. They do not coordinate to keep the same data, so you will want all your clients (for put and get) to point to the same instance of the server. Since you really just want the information from Cassandra, please feel free to file a New Feature Jira to add a CassandraMapCacheServer, then you could fetch the data directly from Cassandra.
... View more
10-25-2018
04:50 PM
Is "Translate Field Names" set to true in PutDatabaseRecord? If not try that. If so, try removing the "namespace":"dbo" from the schema. If that works, then it's probably a bug, as we should be trying to match on fullname but fall back to simple field names.
... View more
10-25-2018
01:28 PM
Do you have multiple concurrent tasks running? If so, you might be running into this issue, and the workaround seems to be to use a single task. If not, are you importing any native (CPython) libraries? You won't be able to do that with Jython, but I thought it gave a different error message in that case.
... View more
10-24-2018
05:41 PM
1 Kudo
Even though it's managed by Hive, unless Hive is performing tasks as the Hive user (which here it is not), I believe Shu is right and you'll likely need an HDFS policy in Ranger to allow user nifi to access the hive warehouse.
... View more
10-22-2018
02:53 PM
There is a mongo-java-driver you can use in either Groovy or Javascript (or any of the scripted languages in ExecuteScript), check my blog on how to use modules.
... View more
10-19-2018
05:54 PM
Your "Database type" property is set to "Generic", try setting it to Oracle (for Oracle < 12) or Oracle 12+.
... View more
10-15-2018
06:59 PM
I'm not sure if I fully understand how your downstream flow would work when there are < 9 flow files available to ExecuteScript, but here's something to try (note that you can use anything greater than 9 in place of the "10" below): def flowFiles = session.get(10) if(flowFiles.size() >= 9) { session.remove(flowFiles) } else { session.transfer(flowFiles, REL_SUCCESS) }
... View more