微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

org.apache.spark.sql.AnalysisException: cannot resolve '`province`' given

Exception in thread "main" 19/01 21:47:32 WARN util.Utils: Truncated the string representation of a plan since it was too large. This behavior can be adjusted by setting 'spark.debug.maxToStringFields' in SparkEnv.conf.
org.apache.spark.sql.AnalysisException: cannot resolve '`province`' given input columns: [bidfloor, isbilling, imeisha1, adprice, apptype, networkmannerid, imeimd5, uuidunkNow, ip, keywords, age, cur, adxrate, ispid, ispname, macsha1, tagid, idfasha1, provincename, adplatformproviderid, lat, openudidmd5, rtbcity, imei, winprice, appname, paymode, cityname, iseffective, district, advertisersid, osversion, rtbprovince, uuid, putinmodeltype, adppprice, androididmd5, requestmode, tel, iswin, pw, networkmannername, channelid, adspacetypename, density, devicetype, adspacetype, androidid, storeurl, aw, device, ph, macmd5, agentrate, cnywinprice, realip, sex, adorderid, requestdate, sdkversion, rate, callbackdate, client, sessionid, rtbstreet, bidprice, adplatformkey, initbidprice, idfa, adpayment, appid, userid, mediatype, lomarkrate, androididsha1, ah, isbid, processnode, iptype, long, openudid, adcreativeid, rtbdistrict, title, mac, email, openudidsha1, isqualityapp, idfamd5]; line 1 pos 7;
'Aggregate [provincename#24, cityname#25], ['province, cityname#25, count(1) AS count#180L]
+- SubqueryAlias ods, `ods`

 

sql字段要和别名对应

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐