Flink SQL> CREATE TABLE pokemon11 (

id VARCHAR,

name VARCHAR,

type VARCHAR,

hp VARCHAR,

attack VARCHAR,

defense VARCHAR,

weakness VARCHAR,

region VARCHAR

)

WITH (

'connector' = 'hive',

'path' = 's3a://clen-test/',

'format' = 'csv',

'csv.field-delimiter' = ',',

'csv.ignore-parse-errors' = 'true'

);

[INFO] Table has been created. Flink SQL> select * from pokemon11; [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.TableSourceFactory' in the classpath. Reason: Required context properties mismatch. The following properties are requested: connector=hive csv.field-delimiter=, csv.ignore-parse-errors=true format=csv path=s3a://aiops-datalake-test/ schema.0.data-type=VARCHAR(2147483647) schema.0.name=id schema.1.data-type=VARCHAR(2147483647) schema.1.name=name schema.2.data-type=VARCHAR(2147483647) schema.2.name=type schema.3.data-type=VARCHAR(2147483647) schema.3.name=hp schema.4.data-type=VARCHAR(2147483647) schema.4.name=attack schema.5.data-type=VARCHAR(2147483647) schema.5.name=defense schema.6.data-type=VARCHAR(2147483647) schema.6.name=weakness schema.7.data-type=VARCHAR(2147483647) schema.7.name=region The following factories have been considered: org.apache.flink.api.java.io.jdbc.JDBCTableSourceSinkFactory org.apache.flink.streaming.connectors.kafka.KafkaTableSourceSinkFactory org.apache.flink.table.sources.CsvBatchTableSourceFactory org.apache.flink.table.sources.CsvAppendTableSourceFactory I got the following error, but i m not sure what i m doing wrong. any suggestions.

Which version of Flink are you using?

i suppose i m a bit late . flink 1.10