您好:
我现在用flink1.10.1版本在研究那个sql-client共hive集成,目前遇到这样一个问题想请教一下:
standalone部署,3台机器,hive用的是cdh5版本 hive1.1.0
按官方文档,进行了集成,hive建的表在flink sql-client下能查询,但反过来,flink
sql-client下建的表无法查询。(sql-client与hive都不能查)
Could not find a suitable table factory for
'org.apache.flink.table.factories.TableSourceFactory' in
the classpath.
Reason: Required context properties mismatch.
The following properties are requested:
schema.0.data-type=INT
schema.0.name=id
The following factories have been considered:
org.apache.flink.table.sources.CsvBatchTableSourceFactory
org.apache.flink.table.sources.CsvAppendTableSourceFactory
好象是少什么包,我查了一下,好象这个包里有flink-table-common-1.10.1.jar,放上去还不行。不知什么问题(详见附件)?
集成要求用的包也都放到了lib下:
flink-connector-hive_2.11-1.10.0.jar
flink-shaded-hadoop-2-uber-2.6.5-8.0.jar
hive-metastore-1.1.0.jar
hive-exec-1.1.0.jar
libfb303-0.9.2.jar