Hi guys, I a csv which contains the contact details (name,email) like: abc,abc@xyz.com xyz,xyz@abc.com I am building a case class and then trying to register the RDD[CaseClass] as data frame following the steps. But endup getting error. error: value toDF is not a member of org.apache.spark.rdd.RDD[Contact] case class Contact(name:String,email:String) val texts = sc.textFile("\pathto\contacts.csv") // doesn't contain headers. val contacts = texts.map(s =>s.split(",")).map(s=>Contact(s(0),s(1))) val contactsDF = contacts.toDF() Can anyone help me understand what's going wrong here? Thanks ... View more

Guys, We have configured A/D with Ranger for a single domain on the Kerberized cluster. The customer requirement is to setup policies for multiple domains.(Namely 5 domains) How do we achieve this on HDP 2.3 cluster? Thank you. ... View more

Hello experts, I am building a use case, one of the part is fetching the emails from email server(s) and want to do some analytics on the emails. Given the credentials can it connect to Email Servers and fetch emails and sink them to HDFS? Is this feature available out of the box in HDF ? What could be alternative or other solution approach to this? ... View more

Hi Guys, I am trying to Kerberizing the cluster and want to integrate with A/D for user authentication. Earlier I've done it using MIT KDC in the HDP cluster and setting bi-directional trust with A/D. But as I remember, the previous step adds couple of entries in the A/D. However, customer does not want to give write access to the A/D. How to proceed in this scenario? Thanks, SS. ... View more

Hi guys, I've installed 2.3.x HDP version on a single node node for now. (Not sandbox). And this machine was shutdown abruptly. And I am trying to start Ambari I am not finding starting script. Could you please help me locate it? on CentOS ... View more