Running Jobs on Managed Apache Spark Rezensionen

Sara U. · Vor fast 6 Jahre überprüft

PRIYA R. · Vor fast 6 Jahre überprüft

Crystal L. · Vor fast 6 Jahre überprüft

Really good, but a few of the steps dont match current Console UI, and some steps are slightly unclear. Concepts are great.

Tony M. · Vor fast 6 Jahre überprüft

Amazing lab - good step-by-step explanation of all processes.

Pavel B. · Vor fast 6 Jahre überprüft

Rex C. · Vor fast 6 Jahre überprüft

Instructions are not very clear. Stuck at many places.

Manish S. · Vor fast 6 Jahre überprüft

Versioning steps are not correct. Advanced Options button no longer present, and Versioning is available on the standard options page.

Douglas H. · Vor fast 6 Jahre überprüft

thara s. · Vor fast 6 Jahre überprüft

Lei X. · Vor fast 6 Jahre überprüft

Jonathan W. · Vor fast 6 Jahre überprüft

student_01_0730aef43f26@cloudshell:~ (qwiklabs-gcp-01-2954a7652416)$ gsutil cp kddcup.data_10_percent.gz gs://$PROJECT_ID/ CommandException: "cp" command does not support provider-only URLs. because of this error this .gz file is not copied to bucket , so cell 4 is failing Py4JJavaError Traceback (most recent call last) <ipython-input-2-ebb0c596a829> in <module> 6 data_file = "gs://"+gcs_bucket+"//kddcup.data_10_percent.gz" 7 raw_rdd = sc.textFile(data_file).cache() ----> 8 raw_rdd.take(5) /usr/lib/spark/python/pyspark/rdd.py in take(self, num) 1325 """ 1326 items = [] -> 1327 totalParts = self.getNumPartitions() 1328 partsScanned = 0 1329 /usr/lib/spark/python/pyspark/rdd.py in getNumPartitions(self) 389 2 390 """ --> 391 return self._jrdd.partitions().size() 392 393 def filter(self, f): /opt/conda/anaconda/lib/python3.6/site-packages/py4j/java_gateway.py in __call__(self, *args) 1255 answer = self.gateway_client.send_command(command) 1256 return_value = get_return_value( -> 1257 answer, self.gateway_client, self.target_id, self.name) 1258 1259 for temp_arg in temp_args: /usr/lib/spark/python/pyspark/sql/utils.py in deco(*a, **kw) 61 def deco(*a, **kw): 62 try: ---> 63 return f(*a, **kw) 64 except py4j.protocol.Py4JJavaError as e: 65 s = e.java_exception.toString() /opt/conda/anaconda/lib/python3.6/site-packages/py4j/protocol.py in get_return_value(answer, gateway_client, target_id, name) 326 raise Py4JJavaError( 327 "An error occurred while calling {0}{1}{2}.\n". --> 328 format(target_id, ".", name), value) 329 else: 330 raise Py4JError( Py4JJavaError: An error occurred while calling o50.partitions. : org.apache.hadoop.mapred.InvalidInputException: Input path does not exist: gs://qwiklabs-gcp-01-2954a7652416/kddcup.data_10_percent.gz at org.apache.hadoop.mapred.LocatedFileStatusFetcher.getFileStatuses(LocatedFileStatusFetcher.java:155) at org.apache.hadoop.mapred.FileInputFormat.listStatus(FileInputFormat.java:244) at org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322) at org.apache.spark.rdd.HadoopRDD.getPartitions(HadoopRDD.scala:204) at org.apache.spark.rdd.RDD$$anonfun$partitions$2.apply(RDD.scala:273) at org.apache.spark.rdd.RDD$$anonfun$partitions$2.apply(RDD.scala:269) at scala.Option.getOrElse(Option.scala:121) at org.apache.spark.rdd.RDD.partitions(RDD.scala:269)

Shashishekar H. · Vor fast 6 Jahre überprüft

Veria H. · Vor fast 6 Jahre überprüft

Denise N. · Vor fast 6 Jahre überprüft

Andrew M. · Vor fast 6 Jahre überprüft

Yang Y. · Vor fast 6 Jahre überprüft

excellent

Andriy P. · Vor fast 6 Jahre überprüft

Vikrant N. · Vor fast 6 Jahre überprüft

Raghunath K. · Vor fast 6 Jahre überprüft

good

Jegan B. · Vor fast 6 Jahre überprüft

Rafael S. · Vor fast 6 Jahre überprüft

Ihor H. · Vor fast 6 Jahre überprüft

Anderson C. · Vor fast 6 Jahre überprüft

Rafael V. · Vor fast 6 Jahre überprüft

muito bom

Michel B. · Vor fast 6 Jahre überprüft