apache-spark – LazyStruct:在行尾检测到额外的字节!忽略类似的问题

我正在开发Hive(HDFS)中的SQL spark读取表中的代码.

问题是,当我在spark的shell中加载我的代码时,递归地传递以下消息:

“WARN LazyStruct:在行尾检测到额外的字节!忽略类似的问题.”

我运行的代码是:

val query_fare_details = sql("""
  SELECT *
  FROM fare_details
  WHERE fardet_cd_carrier = 'LA'
   AND fardet_cd_origin_city = 'SCL'
   AND fardet_cd_dest_city = 'MIA'
   AND fardet_cd_fare_basis = 'NNE0F0O1'
  """)
 query_fare_details.registerTempTable("query_fare_details")

val matchFAR1 = sql("""
  SELECT *
  FROM query_fare_details f
  JOIN fare_rules r ON f.fardet_cd_carrier = r.farrul_cd_carrier 
    AND f.fardet_num_rule_tariff = r.farrul_num_rule_tariff
    AND f.fardet_cd_fare_rule_bigint = r.farrul_cd_fare_rule_bigint
    AND f.fardet_cd_fare_basis = r.farrul_cd_fare_basis
  LIMIT 10""")

matchFAR1.show(5)

知道出了什么问题吗?

最佳答案 你可以放心地忽略这个警告.这不是错误

参考[https://issues.apache.org/jira/browse/SPARK-3057][1]

点赞