I am trying to use the "PutSQL" processor to do just that.
I modify the stream file using "ReplaceText" and create a statement INSERT. I tested this statement in a MySQL database and the instruction works.
Here is the statement:
INSERT INTO monitor.security_nifi (RemoteIPAddress, Timestamp,RequestUrl, Status, Instance)
VALUES ('10.129.2.35', '2016-09-2016:44:16,347','/secure/Dashboard.jspa', 'PASSED', '35');
When it goes through the processor, I keep getting this error:
The session could not be processed due to java.lang.IndexOutOfBoundsException: Index: 1, Size: 1: java.lang.IndexOutOfBoundsException: Index: 1, Size: 1
Here is the stack trace:
2016-09-21 10: 41: 24,658 WARN [Timer-Driven Process Thread-1] oanctContinuallyRunProcessorTask java.lang.IndexOutOfBoundsException: index: 1, size: 1 on java.util.ArrayList.rangeCheck (ArrayList.java:653) ~ [na: 1.8.0_101] at java.util.ArrayList.get (ArrayList.java:429) ~ [na: 1.8.0_101] at org.apache.nifi.processors.standard.PutSQL.onTrigger (PutSQL.java:304 ) ~ [na: na] in org.apache.nifi.processor.AbstractProcessor.onTrigger (AbstractProcessor.java:27) ~ [nifi-api-1.0.0.jar: 1.0.0] at org.apache.nifi.controller .StandardProcessorNode.onTrigger (StandardProcessorNode.java:1064) ~ [nifi-framework-core-1.0.0.jar: 1.0.0] in org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call (ContinuallyRunProcessorTask.java:136) [nifi-framework-core-1.0.0.jar: 1.0.0] on org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call (ContinuallyRunProcessorTask.java:47) [nifi-framework-core-1.0.0.jar: 1.0.0] on org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent $ 1.run (TimerDrivenSchedulingAgent.java:132) [ nifi-framework-core-1.0.0.jar: 1.0.0] on java.util.concurrent.Executors $ RunnableAdapter.call (Executors.javaל11) [na: 1.8.0_101] in java.util.concurrent.FutureTask .runAndReset (FutureTask.java:308) [na: 1.8.0_101] in java.util.concurrent.ScheduledThreadPoolExecutor $ ScheduledFutureTask.access $ 301 (ScheduledThreadPoolExecutor.java:180) [na: 1.8.0_101] in java.util.con ScheduledThreadPoolExecutor $ ScheduledFutureTask.run (ScheduledThreadPoolExecutor.java:294) [na: 1.8.0_101] in java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1142) [na: 1.8.0_101.cur.jcurThreadPoolExecutor $ Worker.run (ThreadPoolExecutor.java:617) [na: 1.8.0_101] in java.lang.Thread.run (Thread.java:745) [Pa: 1.8.0_101]