Commit 49469915 by jinfeng.wang

fix PackageBlackList

parent 84a8bdac
......@@ -49,7 +49,7 @@ class PackageBlackList extends CommonSparkJob with Serializable {
val packageRDD = spark.sql(
"""
|SELECT LOWER(package_name) package_name FROM dwh.dim_package_tag GROUP BY LOWER(package_name)
|SELECT LOWER(package_name) package_name FROM dwh.dim_package_tags GROUP BY LOWER(package_name)
|""".stripMargin)
.rdd.map(r => {
r.getAs[String]("package_name")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment