zoukankan      html  css  js  c++  java
  • Spark1.3使用外部数据源时条件过滤只要是字符串类型的值均报错

    CREATE TEMPORARY TABLE spark_tbls
    USING org.apache.spark.sql.jdbc
    OPTIONS (
    url    'jdbc:mysql://hadoop000:3306/hive?user=root&password=root',
    dbtable     'TBLS'
    );
    select TBL_ID, TBL_NAME from spark_tbls limit 5;
    TBL_ID  TBL_NAME
    126     aaa
    96      abc
    select TBL_ID, TBL_NAME from spark_tbls where TBL_ID=126;
    TBL_ID  TBL_NAME
    126     aaa
    select TBL_ID, TBL_NAME from spark_tbls where TBL_NAME='aaa';

    报错:

    com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException: Unknown column 'aaa' in 'where clause'

    测试发现:只要是字符串类型的过滤条件均报错。

    详见最新master分支的[Spark-6408]

    在测试sparksql操作phoenix时,由于where条件中有字符串类型的值,就一直报错一直报错,后来用MySQL测试了下,发现也是类似的问题,跟踪了源代码发现是Filter出了问题。

  • 相关阅读:
    oracle,mysql对敏感,关键字等处理
    eclipse内置tomcat启动方法
    plsql登录弹白框
    date
    linux乱码
    环境变量
    终端类型
    netstat -aon|findstr 8888 终止进程
    export
    bash环境变量读取顺序
  • 原文地址:https://www.cnblogs.com/luogankun/p/4360729.html
Copyright © 2011-2022 走看看