connet-hive-thift服务器通过pyspark

x33g5p2x  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(167)

我正在尝试使用cloudera配置单元驱动程序com.cloudera.hive.jdbc4.hs2driver连接到远程配置单元节约服务器。我可以连接到它,但在运行任何sql查询时,我不会在结果中获取数据,而只获取列名。我使用的代码是:

df = spark.read \
        .format("jdbc") \
        .option("driver", "com.cloudera.hive.jdbc4.HS2Driver") \
        .option("url", "jdbc:hive2://host:port") \
        .option("dbtable", db_name.table_name) \
        .option("user", usr) \
        .option("password", pwd) \
        .option("properties",{"UseNativeQuery": 1}) \
        .load()
    df.show()

我从日志中知道它正在转换查询并添加一个条件 where 1=0 . 我想是因为这个。但我不能把它去掉。如何解决此问题?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题