We are trying to update "Run Schedule" and "Scheduling Strategy" of a NiFi Processor using REST API (PUT /processors/{id}). This works for most of the processors, but when it is updated for GetSFTP, it overwrites password fields as well and authfail exception occurs. If I update scheduling information using NiFi UI, it works fine. Any thought how we can update scheduling information without bothering about other processor configuration. Appreciate any help. Thanks, Ravi Papisetti ... View more

Hi,   Unable to import SparkSession class that is available from Spark-sql version 2.x. Here is my gradle entry: sparkVersion        = '1.6.0-cdh5.11.0'     spark_sql          = "org.apache.spark:spark-sql_2.10:$sparkVersion"   Here I assume spark-sql_2.10 is spark 2.x version, not 1.6. When I expanded spark-sql_2.10-1.6.0-cdh5.11.0-sources.jar, i don't see SparkSession class in org.apache.spark.sql package.   Can you please clarify when I am not able to see SparkSession class or point to right  repository etnry.   Appreciate your help.   Thanks, Ravi Papisetti     ... View more

NiFi Version 1.3 Creating DBCPConnection Pool "/nifi-api/process-groups/" + processorGrpId + "/controller-services" using nifi 1.3 client. Below is snippet of code updating properties of connection pool service String apiUrl = apiBaseUrl + "/nifi-api/controller-services/" + connectionPoolId; HttpResponse httpResponse = HttpUtil.putRequest(apiUrl, entityJsonString); Here I can see controller entity service with password set. However when QueryDatabaseTable (or any other sql processor) is started, it fails with Processor exception: Cannot create PoolableConnectionFactory (FATAL: password authentication failed for user "xxxxx") I logged into web UI, updated connection pool service manually and it works fine. Same password is used via api and in UI. Wondering why the password didn't work when it is set using API, but works when manually setting on UI. Appreciate any help. Thanks, Ravi Papisetti ... View more