(iceberg testing) DDL parser error when create hive catalog

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

(iceberg testing) DDL parser error when create hive catalog

18717838093

Below is my error, thanks for help, I would like to know ,is it a bug ? 

I followed the website to carry on: https://github.com/apache/iceberg/pull/1464/files

Flink SQL> CREATE CATALOG hive_catalog WITH (
>   'type'='iceberg',
>   'catalog-type'='hive',
>   'uri'='thrift://localhost:9083',
>   'clients'='5',
>   'property-version'='1'
> );
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.CatalogFactory' in
the classpath.

Reason: Required context properties mismatch.

The following properties are requested:
catalog-type=hive
clients=5
property-version=1
type=iceberg
uri=thrift://localhost:9083

The following factories have been considered:
org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory
org.apache.flink.table.catalog.GenericInMemoryCatalogFactory


Reply | Threaded
Open this post in threaded view
|

Re: (iceberg testing) DDL parser error when create hive catalog

OpenInx
Hi 

I'm maintaining the flink sink connector from apache iceberg community,  did your classpath include the correct  iceberg-flink-runtime.jar ?  


Thanks.

On Wed, Oct 21, 2020 at 10:54 PM 18717838093 <[hidden email]> wrote:

Below is my error, thanks for help, I would like to know ,is it a bug ? 

I followed the website to carry on: https://github.com/apache/iceberg/pull/1464/files

Flink SQL> CREATE CATALOG hive_catalog WITH (
>   'type'='iceberg',
>   'catalog-type'='hive',
>   'uri'='thrift://localhost:9083',
>   'clients'='5',
>   'property-version'='1'
> );
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.NoMatchingTableFactoryException: Could not find a suitable table factory for 'org.apache.flink.table.factories.CatalogFactory' in
the classpath.

Reason: Required context properties mismatch.

The following properties are requested:
catalog-type=hive
clients=5
property-version=1
type=iceberg
uri=thrift://localhost:9083

The following factories have been considered:
org.apache.flink.table.catalog.hive.factories.HiveCatalogFactory
org.apache.flink.table.catalog.GenericInMemoryCatalogFactory