spark 连接 impala 错误?

问答 菜鸟程序狗 ⋅ 于 2018-03-12 09:09:54 ⋅ 最后回复由 菜鸟程序狗 2018-03-12 18:30:15 ⋅ 2824 阅读
val spark = SparkSession
  .builder()
  .appName(this.getClass.getName)
  .config(conf)
  .getOrCreate()
val s= spark.read
  .format("jdbc")
  .option("driver", "org.apache.hive.jdbc.HiveDriver")
  .option("url", s"jdbc:hive2://地址:21050/kinglighter;auth=noSasl")
  .option("dbtable", "cf_test_data")
  .load().show()
  为什么在impala中显示   
   SELECT * FROM cf_test_data WHERE 1=0
   SELECT "chooserecommend","recommenduserid","recommendproductonid","recommendnum" FROM cf_test_data 中字段有双引号,不知道哪里出错了,求解?
成为第一个点赞的人吧 :bowtie:
回复数量: 2
  • 青牛 国内首批大数据从业者,就职于金山,担任大数据团队核心研发工程师
    2018-03-12 11:24:21

    在.config(conf) 后面加上".enableHiveSupport()"试试

  • 菜鸟程序狗
    2018-03-12 18:30:15

    @青牛 加上也不行,还是显示不了数据

暂无评论~~
  • 请注意单词拼写,以及中英文排版,参考此页
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`, 更多语法请见这里 Markdown 语法
  • 支持表情,可用Emoji的自动补全, 在输入的时候只需要 ":" 就可以自动提示了 :metal: :point_right: 表情列表 :star: :sparkles:
  • 上传图片, 支持拖拽和剪切板黏贴上传, 格式限制 - jpg, png, gif,教程
  • 发布框支持本地存储功能,会在内容变更时保存,「提交」按钮点击时清空
Ctrl+Enter