Hi! I need to execute following awk command on flow file via ExecuteStreamCommand processor awk -F"," '{OFS=","; $4=substr($4,1,19); print $0}' When run it throws an error: Executable command awk ended in an error: awk: fatal: cannot open file `print $0}" for reading (No such file or directory). Flow file comes from ListFTP -> FetchFTP -> ExecuteStreamCommand Could you please help to solve this issue!! Thank you!! When running the same awk command on server it works fine: awk -F"," '{OFS=","; $4=substr($4,1,19); print $0}' myfile.csv ... View more

Hi! How can I configure InvokeHTTP to return comma separated flow file? At the moment it is returning file in below format (tab separated): RELM Satieva_microloans 6 3369 2019-06-12 11:42:00 772103971 RELM Satieva_microloans 6 3369 2019-06-12 11:42:00 772104117 RELM Satieva_microloans 6 3369 2019-06-12 11:42:00 772101000 Thanks in advance! ... View more

Hi, all! Can anyone give any suggestion in configuring new Ambari server with an existing HDF cluster Previos version of ambari fails in ambari-server start after downgrade [root@bi-nifi1 dmp]# ambari-server start Using python /usr/bin/python Starting ambari-server Ambari Server running with administrator privileges. Organizing resource files at /var/lib/ambari-server/resources... Ambari database consistency check started... Server PID at: /var/run/ambari-server/ambari-server.pid Server out at: /var/log/ambari-server/ambari-server.out Server log at: /var/log/ambari-server/ambari-server.log Waiting for server start.............ERROR: Exiting with exit code -1. REASON: Ambari Server java process has stopped. Please check the logs for more information. [root@bi-nifi1 dmp]# cat /var/log/ambari-server/ambari-server.out Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0 An unexpected error occured during starting Ambari Server. org.apache.ambari.server.AmbariException: An error occured during updating current repository versions with stack repositories. at org.apache.ambari.server.stack.UpdateActiveRepoVersionOnStartup.process(UpdateActiveRepoVersionOnStartup.java:99) at org.apache.ambari.server.orm.AmbariJpaLocalTxnInterceptor.invoke(AmbariJpaLocalTxnInterceptor.java:128) at org.apache.ambari.server.controller.AmbariServer.main(AmbariServer.java:1061) Caused by: java.lang.NullPointerException at org.apache.ambari.server.stack.UpdateActiveRepoVersionOnStartup.updateRepoVersion(UpdateActiveRepoVersionOnStartup.java:106) at org.apache.ambari.server.stack.UpdateActiveRepoVersionOnStartup.process(UpdateActiveRepoVersionOnStartup.java:92) ... 2 more Exception in thread "main" org.apache.ambari.server.AmbariException: Error stopping the server at org.apache.ambari.server.controller.AmbariServer.stop(AmbariServer.java:880) at org.apache.ambari.server.controller.AmbariServer.main(AmbariServer.java:1075) [root@bi-nifi1 dmp]# ... View more

Hi!! I need to run a Linux command on list of files received from ListSFTP (most probably it should be run on remote FTP server) and pass forward the result of this operation as flow file to putHDFS. Linux command is: cat ${LIST} | xargs -n 1 -I {} stdbuf -o 5GB awk -F'\x1b' '{OFS="|"};{print $1,$2,FILENAME}' {} Can you please advise which processor can be most suitable. Thanks in advance! ... View more