Member since
05-10-2016
303
Posts
35
Kudos Received
0
Solutions
12-04-2017
01:27 PM
@Bjorn Olsen: thanks for help, in my controller, i've forgotten "date format". It works as except. thanks
... View more
12-04-2017
10:42 AM
@bjorn : what is the version of nifi, have you used for demo ? I'm using nifi 1.2.0 and the timestamp with "long" not works
... View more
10-20-2017
01:59 PM
@Shu : thanks. I have tried with espace caracter, but i've sent it to splitAvro and got the issue with avro.
... View more
10-20-2017
12:47 PM
Hi all, I've used SelectHiveSQL to make a select but I got an issue it seems that the column name "delta-1", it was not correctly set on the select command.
2017-10-20
14:28:05,805 ERROR [Timer-Driven Process Thread-7]
o.a.nifi.processors.hive.SelectHiveQL SelectHiveQL[id=d3043004]
Unable to execute HiveQL select query select country,year,delta-1 from
table1 for StandardFlowFileRecord[uuid=d1e4662,claim=,offset=0,name=2846304697532889,size=0]
due to org.apache.nifi.processor.exception.ProcessException: org.apache.hive.service.cli.HiveSQLException:
Error while compiling statement:
FAILED:SemanticException [Error 10004]: Line 1:33 Invalid table alias or column
reference 'delta': (possible column names are: country, year, delta-1, ); routing to failure:
org.apache.nifi.processor.exception.ProcessException:
org.apache.hive.service.cli.HiveSQLException: Error while compiling statement:
thanks for helps
... View more
Labels:
- Labels:
-
Apache Hive
-
Apache NiFi
09-30-2017
02:55 PM
Yes. It resolved. I've deleted processor and addition a New one.
... View more
09-04-2017
12:21 PM
Hi all, I Got this error, but i don't know where is an issue in listSFTP processor The command line works sftp -o StrictHostKeyChecking=no -oIdentityFile=/home/xxx/id_dsa XXXX@x.x.33.5 In the processor listFSTP Username : XXXX
Strict Host Key Checking : true or false (same errors)
Host Key File : /home/xxx/id_dsa
And this error : 2017-09-04 14:04:16,655 ERROR [Timer-Driven Process Thread-2] o.a.nifi.processors.standard.ListSFTP ListSFTP[id=3c8b4625-015e-1000-ffff-ffffda2b4cb0] Failed to perform listing on remote host due to java.io.IOException: Failed to obtain connection to remote host due to com.jcraft.jsch.JSchException: Auth fail: {}
java.io.IOException: Failed to obtain connection to remote host due to com.jcraft.jsch.JSchException: Auth fail
at org.apache.nifi.processors.standard.util.SFTPTransfer.getChannel(SFTPTransfer.java:447)
at org.apache.nifi.processors.standard.util.SFTPTransfer.getListing(SFTPTransfer.java:184)
at org.apache.nifi.processors.standard.util.SFTPTransfer.getListing(SFTPTransfer.java:148)
at org.apache.nifi.processors.standard.ListFileTransfer.performListing(ListFileTransfer.java:104)
at org.apache.nifi.processor.util.list.AbstractListProcessor.onTrigger(AbstractListProcessor.java:340)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1120)
at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147)
at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132)
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:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:745)
Caused by: com.jcraft.jsch.JSchException: Auth fail
at com.jcraft.jsch.Session.connect(Session.java:519)
at com.jcraft.jsch.Session.connect(Session.java:183)
at org.apache.nifi.processors.standard.util.SFTPTransfer.getChannel(SFTPTransfer.java:433)
... 16 common frames omitted
thanks for yours helps
... View more
Labels:
- Labels:
-
Apache NiFi
08-24-2017
03:51 PM
Hi all, I'm trying use invokeHTTP to get a digest and token from an API, here my curl command : curl --silent -ik --url https://${OKAPI_HOST}/oauth/access_token -H "Authorization: Bearer $(base64 -w 0 < ${KEYTAB_FILE})" -d grant_type=client_credentials --data-urlencode scope=${SCOPE} how send parameter to invokeHTTP ? I'm thinking use updateAttribute to set scope, Authorization but it don't work. thanks
... View more
Labels:
- Labels:
-
Apache NiFi
07-27-2017
03:21 PM
Hi all,
Anybody already used google ControllerService and GCSBucket ?
I don't know how use it to list bucket.
Without NIFI, i've used gsutil and a configuration file how has these parameters gs_oauth2_refresh_token
proxy
proxy_port Any help welcome
... View more
Labels:
- Labels:
-
Apache NiFi
07-20-2017
09:11 AM
hi all, I'm using NIFI 1.3.0. It seems a bug on segmentContent processor, i can't to set the value. Do you know what's happen ? thanks
... View more
Labels:
- Labels:
-
Apache NiFi