Re:Re: Flink sql 跨库

Wed, 27 May 2020 02:41:25 -0700 


感谢回复，表名前加上Catalog和db前缀可以成功访问了。
现在遇到个问题，flink 读hive 分区表时，如果where子句用分区键，比如year过滤就会报错，用表中其他字段过滤是没问题的，是flink 不支持 
hive分区表，还是哪个地方没设置对














在 2020-05-27 17:33:11，"Leonard Xu" <[email protected]> 写道：
>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 <[email protected]> 写道：
>> 
>> hi all，
>> Flink sql 的HiveCatalog 是不是不能跨库操作啊，就是一个flink 
>> sql中join的两个表涉及到两个不同到库，因为一个HiveCatalog只能关联一个库






















					回复