Hello, HDP里的hive版本是多少啊?另外你要查的表是啥样的呢(describe formatted看一下)?
On Mon, Aug 24, 2020 at 3:02 AM 黄蓉 <[email protected]> wrote: > 各位好: > > > 我使用的环境是HDP3.0.1的沙盒,flink是最新版本的1.11.1,从官网直接下载的编译好的jar包。我想测试flink与hive的集成,包括查询hive表的数据、写入数据到hive表等操作。目前我遇到问题就是通过flink > > sql client查询不出表数据,并且也不报错。但是该表在hive中查询是有记录的。其余的show tables,show > database等语句都可以正常显示。 > > 配置的hadoop环境变量如下: > export HADOOP_CONF_DIR="/etc/hadoop/conf" > export HADOOP_HOME="/usr/hdp/3.0.1.0-187/hadoop" > export > > HADOOP_CLASSPATH="/usr/hdp/current/hadoop-client/*:/usr/hdp/current/hadoop-client/lib/*:/usr/hdp/current/hadoop-hdfs-client/*:/usr/hdp/current/hadoop-hdfs-client/lib/*:/usr/hdp/current/hadoop-yarn-client/*:/usr/hdp/current/hadoop-yarn-client/lib/*:/usr/hdp/current/hadoop-mapreduce-client/*:/usr/hdp/current/hadoop-mapreduce-client/lib/*" > > sql-client配置文件如下: > tables: [] > functions: [] > catalogs: > - name: myhive > type: hive > hive-conf-dir: /opt/hive-conf > execution: > planner: blink > type: batch > result-mode: table > max-table-result-rows: 1000000 > parallelism: 3 > max-parallelism: 128 > min-idle-state-retention: 0 > max-idle-state-retention: 0 > current-catalog: myhive > current-database: default > restart-strategy: > type: fallback > deployment: > response-timeout: 5000 > gateway-address: "" > gateway-port: 0 > > > 请问出现这种情况是不是官网的flink包与hdp3.0.1不兼容?我需要自己重新编译flink吗? > > Jessie > [email protected] > > -- Best regards! Rui Li
