|
@@ -99,6 +99,7 @@ object GraphX4Judicase {
|
|
|
"spark.hadoop.odps.spark.local.partition.amt" -> "2000"
|
|
|
)
|
|
|
val spark: SparkSession = SparkUtils.InitEnv(this.getClass.getSimpleName, config)
|
|
|
+ spark.sparkContext.setLogLevel("All")
|
|
|
attachSparkUITab(spark.sparkContext)
|
|
|
GraphX4Judicase(spark, "winhc_eci_dev", "xjk_ads_judicial_case_relation1", "id_2", "id_1").calc()
|
|
|
}
|