Преглед на файлове

fix:md5接受string类型

晏永年 преди 4 години
родител
ревизия
0afcbf2d5e
променени са 1 файла, в които са добавени 1 реда и са изтрити 1 реда
  1. 1 1
      src/main/scala/com/winhc/bigdata/spark/jobs/GraphX4Judicase.scala

+ 1 - 1
src/main/scala/com/winhc/bigdata/spark/jobs/GraphX4Judicase.scala

@@ -101,7 +101,7 @@ case class GraphX4Judicase(s: SparkSession,
          |FROM(
          |  SELECT B.id AS id
          |        ,B.rowkey
-         |        ,IF(A.judicase_id IS NOT NULL,A.judicase_id,MD5(B.id)) AS judicase_id
+         |        ,IF(A.judicase_id IS NOT NULL,A.judicase_id,MD5(CAST(B.id AS STRING))) AS judicase_id
          |        ,B.case_no
          |        ,B.tn AS flag
          |        ,ROW_NUMBER() OVER (PARTITION BY B.id,B.tn ORDER BY B.id) num