diff --git a/apache-spark/src/main/java/com/baeldung/graphframes/GraphExperiments.java b/apache-spark/src/main/java/com/baeldung/graphframes/GraphExperiments.java index cb5b4c7977..30524a8c8b 100644 --- a/apache-spark/src/main/java/com/baeldung/graphframes/GraphExperiments.java +++ b/apache-spark/src/main/java/com/baeldung/graphframes/GraphExperiments.java @@ -42,7 +42,7 @@ public class GraphExperiments { private void doGraphFrameAlgorithms(GraphFrame graph) { - graph.pageRank().maxIter(20).resetProbability(0.0001).run().vertices().show(); + graph.pageRank().maxIter(20).resetProbability(0.15).run().vertices().show(); graph.connectedComponents().run().show(); diff --git a/apache-spark/src/main/java/com/baeldung/graphframes/GraphLoader.java b/apache-spark/src/main/java/com/baeldung/graphframes/GraphLoader.java index 084af4fac4..cad1fb4e26 100644 --- a/apache-spark/src/main/java/com/baeldung/graphframes/GraphLoader.java +++ b/apache-spark/src/main/java/com/baeldung/graphframes/GraphLoader.java @@ -27,7 +27,7 @@ public class GraphLoader { Path temp = Files.createTempDirectory("sparkGraphFrames"); SparkSession session = SparkSession.builder() .appName("SparkGraphFrameSample") - .config("spark.sql.warehouse.dir", temp.toString())//"/file:C:/temp" + .config("spark.sql.warehouse.dir", temp.toString()) .sparkContext(getSparkContext().sc()) .master("local[*]") .getOrCreate(); diff --git a/apache-spark/src/main/java/com/baeldung/graphframes/User.java b/apache-spark/src/main/java/com/baeldung/graphframes/User.java index 475a9c13ad..50022a1da1 100644 --- a/apache-spark/src/main/java/com/baeldung/graphframes/User.java +++ b/apache-spark/src/main/java/com/baeldung/graphframes/User.java @@ -22,6 +22,6 @@ public class User implements Serializable { @Override public String toString() { - return "struct<" + id + "," + name + ">"; + return "<" + id + "," + name + ">"; } }