About ManishaJain

witnessthevil · ‎10-07-2022

Hi, I have been following your instruction. If I want to do the same thing, but with pyspark, will the code similar to this?

federico_facca · ‎02-16-2018

@manisha jain i am struggling to understand how it is supposed to work. do the client need to authenticate with the certificate also if you are using oidc? I thought that only a working certificate was needed in the keystore for that, and that nothing regarding the identity was needed using oidc (given that identity is covered by oidc). any example of how you did configure your system would be appreciated.

ManishaJain · ‎11-13-2017

@Umair Khan Thanks for the template . Have another question ,suppose i have a threshold interval of 10 min but would like monitor only twice (10 min + 10 min)and not every 10 min ,how can that be done?

abhinav_joshi · ‎04-27-2018

@Ok , I managed to get this fixed. In oracle I can see it works a little differently. I used the following and this worked.I passed the table name followed by a "." and that seemed to do the trick. @Shu GIM.GIDB_GC_SKILL.*,'${now():toNumber():format('yyyy-MM-dd HH:mm:ss')}' AS LOAD_TMS

wcbdata · ‎11-06-2017

We use separate, nested processor groups to segregate by developer and subject area. The navigation can get to be a little much, but it keeps things relatively isolated until we migrate from a dev-centric structure to a subject-oriented structure for production.

Bharat · ‎11-21-2018

@Matt Clarke @Shu Thanks for you quick response Matt. Yes you are correct. It's working now. However I did not understood, unless I create a outport in PG1 I am unable to create a connection at root level to another PG2 via outport. Any idea why is that so?

mkalyanpur · ‎09-09-2017

Have you tried using the kafkaProcessors already present in NiFi? https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-9-nar/1.3.0/org.apache.nifi.processors.kafka.pubsub.PublishKafka/index.html https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-10-nar/1.3.0/org.apache.nifi.processors.kafka.pubsub.PublishKafka_0_10/index.html https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-10-nar/1.3.0/org.apache.nifi.processors.kafka.pubsub.PublishKafkaRecord_0_10/index.html

ManishaJain · ‎09-07-2017

Thanks @Yash i have used the same approach,it works.

ManishaJain · ‎08-23-2017

Thanks @Venkata Sudheer Kumar M .You rightly pointed the issue. Command was executing by default as root user. Resolution: I later updated the property under Nifi conf folder in the file bootstrap.conf as below run.as:hadoop The command execution was now as hadoop user and it ran successfully. Sqoop export is invokable via nifi execute processor.

Online	Offline
Last Visited	‎05-06-2020 12:02 PM

Member Since	‎03-23-2019 10:10 AM
Last Visited	‎05-06-2020 12:02 PM
Posts	26
Kudos received	1

Cloudera Community

Re: Apache NiFi - Authentication with OpenID Conne...

Re: Apache Nifi : using Sqoop export command in ex...

Re: NiFi + Spark : Feeding Data to Spark Streamin...

Re: Apache NiFi - Authentication with OpenID Conne...

Re: Nifi : Alert mail to be sent when file not fou...

Re: Nifi : QueryDatabaseProcessor - Add new fields...

Re: Nifi - Is there a way to add a new work area i...

Re: NiFi - Output Port : Not able to enable the tr...

Re: Is it possible to invoke Kafka Producer from N...

Re: On Nifi Is it possible using PutHdfs Processor...

Re: Apache Nifi : using Sqoop export command in ex...