./bin/flink run -p2 -c com.ydx.streaming.StreamingGoodsDetailJob /opt/module/flink-1.11.2/examples/batch/StreamingRecommender-1.0-SNAPSHOT.jar

源码

class GoodsDetailPageFlatMapFunction extends FlatMapFunction[String, GoodsDetailPage] {
override def flatMap(t: String, collector: Collector[GoodsDetailPage]): Unit = {
if (t.nonEmpty){
  if(t.contains("\"page\":")) {
    val pageObj = JSON.parseObject(JSON.parseObject(t).getString("page"))
    if(pageObj.getString("page_id") == "good_detail"){
      if(pageObj.getString("item").nonEmpty){
        val jsonOBJ :JSONObject  = JSON.parseObject(t)
        val comObj = JSON.parseObject(jsonOBJ.getString("common"))
        if(comObj.getString("uid").nonEmpty){
          collector.collect(
            GoodsDetailPage(
              uid = comObj.getString("uid"),
              item_type = pageObj.getString("item_type"),
              item = pageObj.getString("item"),
              during_time = pageObj.getString("during_time").toInt,
              ts = jsonOBJ.getString("ts").toLong,
              time_server = jsonOBJ.getString("server_time").toLong,
              first_time = jsonOBJ.getString("server_time").toLong,
              reason = "得分：" + 0
            )
          )
        }

      }
    }
  }
}
}
}

生产报错信息如下：

• Caused by: java.lang.ClassNotFoundException: com.alibaba.fastjson.JSON （val pageObj = JSON.parseObject(JSON.parseObject(t).getString("page"))） idea中正常，但生产环境中就报错