[jira] [Created] (NIFI-12211) TinkerpopClientService is enable-able when setting the username or password in the service
Levi Lentz created NIFI-12211:
-
Summary: TinkerpopClientService is enable-able when setting the
username or password in the service
Key: NIFI-12211
URL: https://issues.apache.org/jira/browse/NIFI-12211
Project: Apache NiFi
Issue Type: Bug
Reporter: Levi Lentz
Assignee: Levi Lentz
In the TinkperpopClientService we are missing validators on the username and
password as introduced by this PR:
[https://github.com/apache/nifi/pull/7677]
Example stacktrace when setting the username/password:
{code:java}
java.lang.IllegalStateException: Cannot enable Controller Service
TestableGremlinClientService[id=gremlinService] because it is in an invalid
state: 'user-name' validated against 'test' is invalid because 'user-name' is
not a supported property or has no Validator associated with it
{code}
The fix:
Add Validators.VALID to the username/password fields.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
[jira] [Created] (NIFI-9302) As a developer, I want the ability to use controller services in the ExecuteQuery and ExecuteGraphQueryRecord processors so that I can have more fine-tuned control of my g
Levi Lentz created NIFI-9302: Summary: As a developer, I want the ability to use controller services in the ExecuteQuery and ExecuteGraphQueryRecord processors so that I can have more fine-tuned control of my graph mutations Key: NIFI-9302 URL: https://issues.apache.org/jira/browse/NIFI-9302 Project: Apache NiFi Issue Type: Improvement Reporter: Levi Lentz Assignee: Levi Lentz Like the ExecuteGroovy processors, the ability to use a CTL-like service within the groovy script would be very valuable to extend the graph processors to use additional nifi capabilities such as the DistributedMapCache. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (NIFI-9286) As a developer, I want to add in the ability to use expression language in the Jolt tranformation processors so that I can use custom expression language to specify the jo
Levi Lentz created NIFI-9286: Summary: As a developer, I want to add in the ability to use expression language in the Jolt tranformation processors so that I can use custom expression language to specify the jolt transformation dynamically. Key: NIFI-9286 URL: https://issues.apache.org/jira/browse/NIFI-9286 Project: Apache NiFi Issue Type: Improvement Reporter: Levi Lentz Assignee: Levi Lentz In the current jolt processors (both the joltJSON and JoltRecord), they are inflexible when it comes to custom transformation specification because of the lack of expression language support. Additionally, the dynamic modification of the classpath is not implemented correctly, leading to issues in specifying a custom transform method in a jar-file as outlined in NIFI-6213. This ticket will add the above functionality and address the issues outlined in NIFI-6213. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Assigned] (NIFI-6213) Custom Transformation Class not found with JoltTransformJSON Processor
[
https://issues.apache.org/jira/browse/NIFI-6213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Levi Lentz reassigned NIFI-6213:
Assignee: Levi Lentz
> Custom Transformation Class not found with JoltTransformJSON Processor
> --
>
> Key: NIFI-6213
> URL: https://issues.apache.org/jira/browse/NIFI-6213
> Project: Apache NiFi
> Issue Type: Bug
>Affects Versions: 1.9.1, 1.9.2
> Environment: Ubuntu 16.04
>Reporter: Karel
>Assignee: Levi Lentz
>Priority: Major
> Attachments: jolt-processor-config.png
>
>
> Jolt Processor fails to load the custom transform class from the "Custom
> Module Directory" when executing the flow.
> I have implemented the com.bazaarvoice.jolt.Transform and SpecDriven
> interfaces and have compiled all its dependencies into a single jar. I've
> placed the jar to a directory "/data/bin/nifi-1.9.1/jolt_modules".
> My configuration looks like this:
>
> !jolt-processor-config.png!
> The processor validates itself ok, but when running the flow it shows
> exception:
> {noformat}
> 2019-04-01 14:30:54,196 ERROR [Timer-Driven Process Thread-4]
> o.a.n.p.standard.JoltTransformJSON
> JoltTransformJSON[id=b407714f-0169-1000-d9b2-1709069238d7] Unable to
> transform
> StandardFlowFileRecord[uuid=72dc471b-c587-4da9-b54c-eb46247b0cf4,claim=StandardContentClaim
> [resourceClaim=StandardResourceClaim[id=1554129053747-21203,
> container=default, section=723], offset=607170,
> length=5363],offset=0,name=72dc471b-c587-4da9-b54c-eb46247b0cf4,size=5363]
> due to java.util.concurrent.CompletionException:
> java.lang.ClassNotFoundException:
> org.sentilo.nifi.elasticsearch.ElasticsearchToOpenTSDB:
> java.util.concurrent.CompletionException: java.lang.ClassNotFoundException:
> org.sentilo.nifi.elasticsearch.ElasticsearchToOpenTSDB
> java.util.concurrent.CompletionException: java.lang.ClassNotFoundException:
> org.sentilo.nifi.elasticsearch.ElasticsearchToOpenTSDB
> at
> com.github.benmanes.caffeine.cache.BoundedLocalCache$BoundedLocalLoadingCache.lambda$new$0(BoundedLocalCache.java:3373)
> at
> com.github.benmanes.caffeine.cache.BoundedLocalCache.lambda$doComputeIfAbsent$14(BoundedLocalCache.java:2039)
> at
> java.util.concurrent.ConcurrentHashMap.compute(ConcurrentHashMap.java:1853)
> at
> com.github.benmanes.caffeine.cache.BoundedLocalCache.doComputeIfAbsent(BoundedLocalCache.java:2037)
> at
> com.github.benmanes.caffeine.cache.BoundedLocalCache.computeIfAbsent(BoundedLocalCache.java:2020)
> at
> com.github.benmanes.caffeine.cache.LocalCache.computeIfAbsent(LocalCache.java:112)
> at
> com.github.benmanes.caffeine.cache.LocalLoadingCache.get(LocalLoadingCache.java:67)
> at
> org.apache.nifi.processors.standard.JoltTransformJSON.getTransform(JoltTransformJSON.java:316)
> at
> org.apache.nifi.processors.standard.JoltTransformJSON.onTrigger(JoltTransformJSON.java:277)
> at
> org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
> at
> org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)
> at
> org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:205)
> at
> org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.ClassNotFoundException:
> org.sentilo.nifi.elasticsearch.ElasticsearchToOpenTSDB
> at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
> at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
> at
> org.apache.nifi.processors.standard.util.jolt.TransformFactory.getCustomTransform(TransformFactory.java:65)
> at
> org.apache.nifi.processors.standard.JoltTransformJSON.createTransform(JoltTransformJSON.java:346)
> at
> org.apache.nifi.processors.standard.JoltTransformJSON.lambda$setup$0(JoltTransformJSON.java:324)
> at
>
[jira] [Assigned] (NIFI-7906) Add graph processor with flexibility to query graph database conditioned on flowfile content and attirbutes
[ https://issues.apache.org/jira/browse/NIFI-7906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Levi Lentz reassigned NIFI-7906: Assignee: Levi Lentz > Add graph processor with flexibility to query graph database conditioned on > flowfile content and attirbutes > --- > > Key: NIFI-7906 > URL: https://issues.apache.org/jira/browse/NIFI-7906 > Project: Apache NiFi > Issue Type: New Feature >Reporter: Levi Lentz >Assignee: Levi Lentz >Priority: Minor > Labels: graph > Fix For: 1.13.0 > > > The current graph bundle currently does not allow you to query the graph > database (as defined in the GraphClientService) with attributes or content > available in the flow file. > > This functionality would allow uses to perform dynamic queries/mutations of > the underlying graph data based. -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Created] (NIFI-7906) Add graph processor with flexibility to query graph database conditioned on flowfile content and attirbutes
Levi Lentz created NIFI-7906: Summary: Add graph processor with flexibility to query graph database conditioned on flowfile content and attirbutes Key: NIFI-7906 URL: https://issues.apache.org/jira/browse/NIFI-7906 Project: Apache NiFi Issue Type: New Feature Reporter: Levi Lentz Fix For: 1.13.0 The current graph bundle currently does not allow you to query the graph database (as defined in the GraphClientService) with attributes or content available in the flow file. This functionality would allow uses to perform dynamic queries/mutations of the underlying graph data based. -- This message was sent by Atlassian Jira (v8.3.4#803005)
