thanks, it works. ... View more

looks like zeppelin issue and your coding is working great. Thanks a lot. ... View more

thaks a lot. It works through command line shell. not working through zeppelin content = sc.textFile("file:///path/example.txt") ... View more

thank you so much. content = sc.textFile("file:///home/userid/test.txt") Is it the right syntax or does it need to be pointed to HDFS only? I am getting the following error message. An error occurred while calling z:org.apache.spark.api.python.PythonRDD.collectAndServe. : org.apache.hadoop.mapred.InvalidInputException: Input path does not exist: file:/home/userid/test.txt at org.apache.hadoop.mapred.FileInputFormat.singleThreadedListStatus(FileInputFormat.java:287) at org.apache.hadoop.mapred.FileInputFormat.listStatus(FileInputFormat.java:229) at org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:315) at org.apache.spark.rdd.HadoopRDD.getPartitions(HadoopRDD.scala:199) at org.apache.spark.rdd.RDD$anonfun$partitions$2.apply(RDD.scala:252) at org.apache.spark.rdd.RDD$anonfun$partitions$2.apply(RDD.scala:250) at scala.Option.getOrElse(Option.scala:121) at org.apache.spark.rdd.RDD.partitions(RDD.scala:250) at org.apache.spark.rdd.MapPartitionsRDD.getPartitions(MapPartitionsRDD.scala:35) at org.apache.spark.rdd.RDD$anonfun$partitions$2.apply(RDD.scala:252) at org.apache.spark.rdd.RDD$anonfun$partitions$2.apply(RDD.scala:250) at scala.Option.getOrElse(Option.scala:121) ... View more

thank you, How do I read the contents? ... View more

I would like read the contents of unix file, /path/example.txt ... View more

I am curious, how about solr, does it need to be up and running before Atlas comes up? Or only Hbase? ... View more