2回答

小蜗牛快点儿跑

提问者

2020-09-10

val PlayerUid = WarDataStream.map(data=>((data.strPlayerUid,"player_num"),1L)).keyBy(_._1)
  .timeWindow(Time.minutes(5)).sum(1)
if (PlayerUid != null){
   PlayerUid.addSink(new CountDao())
}

0

1

Michael_PK

123行代码，加上日志，判断可能的对象是否是空就行了

2020-09-10

共1条回复

Michael_PK

2020-09-10

空指针异常，肯定是你的代码open里面没有真正获取到对象，随意导致后续该对象的方法调用时出现的npe异常了。根据异常信息直接定位到你的代码，你可以加个日志把空指针的对象输出就知道肯定没有获取到对象了

0

1

小蜗牛快点儿跑

老师我的是流数据进来的，可能会没有数据，可是我设置了判断空值 val PlayerUid = WarDataStream.map(data=>((data.strPlayerUid,"player_num"),1L)).keyBy(_._1) .timeWindow(Time.minutes(5)).sum(1) if (PlayerUid != null){ PlayerUid.addSink(new CountDao()) } open的是MySQL jdbc 代码如下: try { classOf[com.mysql.jdbc.Driver] conn = DriverManager.getConnection(mysql_conn, mysql_user, mysql_pass) insertStmt = conn.prepareStatement("INSERT into count SQL") upavgStmt = conn.prepareStatement("update count SQL") } catch { case e: Exception => e.printStackTrace() } finally { if (conn == null) { conn.close() } }

2020-09-10

共1条回复