Flink 支持hive分区表的，看你在另外一个邮件里贴了，你能把你的hive表和query在邮件里贴下吗？
祝好 Leonard Xu > 在 2020年5月27日，17:40，Zhou Zach <wander...@163.com> 写道： > > > > > 感谢回复，表名前加上Catalog和db前缀可以成功访问了。 > 现在遇到个问题，flink 读hive 分区表时，如果where子句用分区键，比如year过滤就会报错，用表中其他字段过滤是没问题的，是flink 不支持 > hive分区表，还是哪个地方没设置对 > > > > > > > > > > > > > > > 在 2020-05-27 17:33:11，"Leonard Xu" <xbjt...@gmail.com> 写道： >> Hi， >>> 因为一个HiveCatalog只能关联一个库 >> 一个Catalog是可以关联到多个db的，不同catalog，不同db中表都可以访问的. >> >> Flink SQL> show catalogs; >> default_catalog >> myhive >> Flink SQL> use catalog myhive; >> Flink SQL> show databases; >> default >> hive_test >> hive_test1 >> Flink SQL> select * from hive_test.db2_table union select * from >> myhive.hive_test1.db1_table; >> 2020-05-27 17:25:48,565 INFO org.apache.hadoop.hive.conf.HiveConf >> >> >> >> 祝好 >> Leonard Xu >> >> >>> 在 2020年5月27日，10:55，Zhou Zach <wander...@163.com> 写道： >>> >>> hi all， >>> Flink sql 的HiveCatalog 是不是不能跨库操作啊，就是一个flink >>> sql中join的两个表涉及到两个不同到库，因为一个HiveCatalog只能关联一个库
