Prepare Data for ML APIs on Google Cloud : atelier challenge avis

Hemanth K. · Examiné il y a 4 mois

Alana G. · Examiné il y a 4 mois

Celso C. · Examiné il y a 4 mois

Gustavo F. · Examiné il y a 4 mois

Kaylane B. · Examiné il y a 4 mois

rebeca r. · Examiné il y a 4 mois

KRISHNA G. · Examiné il y a 4 mois

DUBBUDU T. · Examiné il y a 4 mois

Ci L. · Examiné il y a 4 mois

Joao A. · Examiné il y a 4 mois

JITTA A. · Examiné il y a 4 mois

Jagadeesh D. · Examiné il y a 4 mois

Garyee T. · Examiné il y a 4 mois

confusing

Irene L. · Examiné il y a 4 mois

Michael O. · Examiné il y a 4 mois

Franco C. · Examiné il y a 4 mois

André d. · Examiné il y a 4 mois

Unable to finish. Dataproc job gave the following error: Caused by: java.lang.NoClassDefFoundError: scala/math/Ordering at org.apache.spark.examples.SparkPageRank.main(SparkPageRank.scala)

John H. · Examiné il y a 4 mois

Muhammad Zahran A. · Examiné il y a 4 mois

Try 3 time to create the jobs always fail... WARN: This is a naive implementation of PageRank and is given as an example! Please use the PageRank implementation found in org.apache.spark.graphx.lib.PageRank for more conventional use. 24/06/10 14:24:21 INFO SparkEnv: Registering MapOutputTracker 24/06/10 14:24:22 INFO SparkEnv: Registering BlockManagerMaster 24/06/10 14:24:22 INFO SparkEnv: Registering BlockManagerMasterHeartbeat 24/06/10 14:24:22 INFO SparkEnv: Registering OutputCommitCoordinator 24/06/10 14:24:23 INFO DefaultNoHARMFailoverProxyProvider: Connecting to ResourceManager at cluster-e74d-m.us-central1-b.c.qwiklabs-gcp-03-347f94788cfb.internal./10.128.0.10:8032 24/06/10 14:24:24 INFO AHSProxy: Connecting to Application History server at cluster-e74d-m.us-central1-b.c.qwiklabs-gcp-03-347f94788cfb.internal./10.128.0.10:10200 24/06/10 14:24:25 INFO Configuration: resource-types.xml not found 24/06/10 14:24:25 INFO ResourceUtils: Unable to find 'resource-types.xml'. 24/06/10 14:24:27 INFO YarnClientImpl: Submitted application application_1718029314860_0001 24/06/10 14:24:29 INFO DefaultNoHARMFailoverProxyProvider: Connecting to ResourceManager at cluster-e74d-m.us-central1-b.c.qwiklabs-gcp-03-347f94788cfb.internal./10.128.0.10:8030 24/06/10 14:24:33 INFO MetricsConfig: Loaded properties from hadoop-metrics2.properties 24/06/10 14:24:33 INFO MetricsSystemImpl: Scheduled Metric snapshot period at 10 second(s). 24/06/10 14:24:33 INFO MetricsSystemImpl: google-hadoop-file-system metrics system started 24/06/10 14:24:34 INFO GoogleCloudStorageImpl: Ignoring exception of type GoogleJsonResponseException; verified object already exists with desired state. 24/06/10 14:24:36 INFO GoogleHadoopOutputStream: hflush(): No-op due to rate limit (RateLimiter[stableRate=0.2qps]): readers will *not* yet see flushed data for gs://dataproc-temp-us-central1-216016258895-fbueqx14/75101875-af16-49fd-8747-a9f5efd70ab8/spark-job-history/application_1718029314860_0001.inprogress [CONTEXT ratelimit_period="1 MINUTES" ] Exception in thread "main" org.apache.spark.sql.AnalysisException: [PATH_NOT_FOUND] Path does not exist: hdfs://cluster-e74d-m/data.txt. at org.apache.spark.sql.errors.QueryCompilationErrors$.dataPathNotExistError(QueryCompilationErrors.scala:1500) at org.apache.spark.sql.execution.datasources.DataSource$.$anonfun$checkAndGlobPathIfNecessary$4(DataSource.scala:757) at org.apache.spark.sql.execution.datasources.DataSource$.$anonfun$checkAndGlobPathIfNecessary$4$adapted(DataSource.scala:754) at org.apache.spark.util.ThreadUtils$.$anonfun$parmap$2(ThreadUtils.scala:380) at scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659) at scala.util.Success.$anonfun$map$1(Try.scala:255) at scala.util.Success.map(Try.scala:213) at scala.concurrent.Future.$anonfun$map$1(Future.scala:292) at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33) at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64) at java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1426) at java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290) at java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020) at java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656) at java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594) at java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)

Kabuqueci S. · Examiné il y a 4 mois

very hard lab

Werner S. · Examiné il y a 4 mois

André d. · Examiné il y a 4 mois

no instructions on how to save file to gc storage from ssh command line

Michał S. · Examiné il y a 4 mois

GADDE K. · Examiné il y a 4 mois

Flavio L. · Examiné il y a 4 mois