Put flink-connector-hive jar in classpath
On Sun, Aug 25, 2019 at 9:14 AM Yebgenya Lazarkhosrouabadi < lazarkhosrouab...@integration-factory.de> wrote: > Hello, > > > > I’m trying to use hivecatalog in flink1.9. I modified the yaml file like > this: > > > > > > catalogs: > > - name: mynewhive > > type: hive > > hive-conf-dir: /home/user/Downloads/apache-hive-1.2.2-bin/conf > > default-database: myhive > > > > > > But when I try to run *./sql-client.sh embedded * I get this error: > > > > Exception in thread "main" > org.apache.flink.table.client.SqlClientException: The configured > environment is invalid. Please check your environment files again. > > at > org.apache.flink.table.client.SqlClient.validateEnvironment(SqlClient.java:147) > > at > org.apache.flink.table.client.SqlClient.start(SqlClient.java:99) > > at > org.apache.flink.table.client.SqlClient.main(SqlClient.java:194) > > Caused by: org.apache.flink.table.client.gateway.SqlExecutionException: > Could not create execution context. > > at > org.apache.flink.table.client.gateway.local.LocalExecutor.getOrCreateExecutionContext(LocalExecutor.java:553) > > at > org.apache.flink.table.client.gateway.local.LocalExecutor.validateSession(LocalExecutor.java:373) > > at > org.apache.flink.table.client.SqlClient.validateEnvironment(SqlClient.java:144) > > ... 2 more > > Caused by: org.apache.flink.table.api.NoMatchingTableFactoryException: > Could not find a suitable table factory for > 'org.apache.flink.table.factories.CatalogFactory' in > > the classpath. > > > > Reason: No context matches. > > > > The following properties are requested: > > default-database=myhive > > hive-conf-dir=/home/bernadette/Downloads/apache-hive-1.2.2-bin/conf > > type=hive > > > > The following factories have been considered: > > org.apache.flink.table.catalog.GenericInMemoryCatalogFactory > > org.apache.flink.table.sources.CsvBatchTableSourceFactory > > org.apache.flink.table.sources.CsvAppendTableSourceFactory > > org.apache.flink.table.sinks.CsvBatchTableSinkFactory > > org.apache.flink.table.sinks.CsvAppendTableSinkFactory > > org.apache.flink.table.planner.StreamPlannerFactory > > org.apache.flink.table.executor.StreamExecutorFactory > > org.apache.flink.table.planner.delegation.BlinkPlannerFactory > > org.apache.flink.table.planner.delegation.BlinkExecutorFactory > > at > org.apache.flink.table.factories.TableFactoryService.filterByContext(TableFactoryService.java:283) > > at > org.apache.flink.table.factories.TableFactoryService.filter(TableFactoryService.java:191) > > at > org.apache.flink.table.factories.TableFactoryService.findSingleInternal(TableFactoryService.java:144) > > at > org.apache.flink.table.factories.TableFactoryService.find(TableFactoryService.java:114) > > at > org.apache.flink.table.client.gateway.local.ExecutionContext.createCatalog(ExecutionContext.java:258) > > at > org.apache.flink.table.client.gateway.local.ExecutionContext.lambda$new$0(ExecutionContext.java:136) > > at java.util.HashMap.forEach(HashMap.java:1289) > > at > org.apache.flink.table.client.gateway.local.ExecutionContext.<init>(ExecutionContext.java:135) > > at > org.apache.flink.table.client.gateway.local.LocalExecutor.getOrCreateExecutionContext(LocalExecutor.java:549) > > ... 4 more > > > > > > > > How can I get rid of this error? > > > > Best regards > > Yebgenya Lazar > HINWEIS: Dies ist eine vertrauliche Nachricht und nur für den Adressaten > bestimmt. Es ist nicht erlaubt, diese Nachricht zu kopieren oder Dritten > zugänglich zu machen. Sollten Sie diese Nachricht irrtümlich erhalten > haben, bitte ich um Ihre Mitteilung per E-Mail oder unter der oben > angegebenen Telefonnummer. >
