Member since
09-08-2016
19
Posts
1
Kudos Received
4
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
934 | 01-26-2018 11:25 PM | |
17215 | 10-09-2017 04:23 PM | |
4721 | 07-18-2017 04:15 PM | |
25693 | 09-21-2016 10:55 AM |
01-26-2018
11:25 PM
Ignore this, got is resolved by sending only schedule-related information in the put request, instead of whole processor configuration. This got resolved.
... View more
01-26-2018
10:38 PM
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
Labels:
- Labels:
-
Apache NiFi
10-24-2017
03:56 PM
The reason is not authorizations.xml (not updated during these times.). It is varying: Sometimes it is as folows 2017-10-23 09:02:23,516 INFO [Process Cluster Protocol Request-6] o.a.n.c.c.node.NodeClusterCoordinator Status of creando-qa26.cisco.com:8090 changed from NodeConnectionStatus[nodeId=hostxxx:8090, state=DISCONNECTED, Disconnect Code=Failed to Service Request, Disconnect Reason=Failed to process request POST /nifi-api/process-groups/487c7858-015f-1000-0000-000028594ca6/template-instance, updateId=48] to NodeConnectionStatus[nodeId=nodexxx:8090, state=REMOVED, updateId=51] Another time it said node was shutdown. Checking our infra why it got restarted during that time.
... View more
10-24-2017
03:25 PM
Hi, This workaround is working, but it is happening kind of frequently in our environment and very annoying. Why is nifi node not able to get the latest copy from primary node and join the cluster automatically? Appreciate if you can share any insights why this happens and any reliable solution?
... View more
10-20-2017
03:59 PM
We are getting same error, please post if you found any solution for this error.
... View more
10-09-2017
04:23 PM
This issue got resolved after changing to spark 2.1 version. I understand that in cloudera mvn artifactory, number associated to spark-core-2.10 is scala version, 1.6.0 associated with CDH is spark version.
... View more
10-06-2017
09:43 AM
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
Labels:
- Labels:
-
Apache HBase
07-18-2017
04:15 PM
This issue has been resolved. While creating the controller service, it got all parameters set and returned the object. Returned object has a masked password (****). When application changing the controller service state from disabled to enabled, controller service entity is being updated with a masked password. Hence it fails to connect to the database. During the state change, we resend the original password to fix the issue. Thanks to Arpit Gupta who helped me in resolving this issue.
... View more
07-11-2017
12:25 AM
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
Labels:
- Labels:
-
Apache NiFi
10-21-2016
10:05 PM
1 Kudo
Hi, I got into very similar issue. Did you find a way to run shell with kerberos principal. We are trying to do the same, wrap the sqoop script inside shell and use ExecuteProcess processor. It fails to execute with GSS credentials exception. We tried to start the nifi service with 'nifi' user that has nifi service principal. We want nifi to use user kerberos principal while running this sqoop script. Any thoughts?
... View more