【发布时间】:2022-01-21 07:55:05
【问题描述】:
我在 Spark 中阅读了 JSON,但是,我收到了一些关于 Hive 的警告。我没有在笔记本电脑上设置 Hive。我使用的代码是:
scala> val dfs = spark.sql("SELECT * FROM json.`/Users/name/Desktop/constituents.json`")
21/12/18 23:48:08 WARN HiveConf: HiveConf of name hive.stats.jdbc.timeout does not exist
21/12/18 23:48:08 WARN HiveConf: HiveConf of name hive.stats.retries.wait does not exist
21/12/18 23:48:13 WARN ObjectStore: Version information not found in metastore. hive.metastore.schema.verification is not enabled so recording the schema version 2.3.0
21/12/18 23:48:13 WARN ObjectStore: setMetaStoreSchemaVersion called but recording version is disabled: version = 2.3.0, comment = Set by MetaStore shashanksathish@127.0.0.1
21/12/18 23:48:13 WARN ObjectStore: Failed to get database default, returning NoSuchObjectException
21/12/18 23:48:14 WARN ObjectStore: Failed to get database global_temp, returning NoSuchObjectException
21/12/18 23:48:14 WARN ObjectStore: Failed to get database json, returning NoSuchObjectException
dfs: org.apache.spark.sql.DataFrame = [Name: string, Sector: string ... 1 more field]
我无法理解数据是如何加载到我的变量中的。
【问题讨论】:
标签: apache-spark hive apache-spark-sql