hi,
 我使用 sql-client 读取parquet文件,报错:
[ERROR] Could not execute SQL statement. Reason:
java.lang.ClassNotFoundException: 
org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat


Flink版本:1.15.0/1.15.1


SQL语句:
Flink SQL> CREATE TABLE orders_parquet (
>   int32_field            INT,
>   int32_field1           INT,
>   int32_field2           INT
> ) WITH (
>  'connector' = 'filesystem',
>  'path' = '/data/testdata/PARQUET-10000_4',
>  'format' = 'parquet'
> );
[INFO] Execute statement succeed.


Flink SQL> select * from orders_parquet where int32_field > 100;


Lib包如下:


[root@icx20 flink-1.15.1]# ll lib/
total 212528
-rw-r--r--. 1 root root     62050 Jul 11 19:27 commons-logging-1.1.3.jar
-rw-r--r--. 1 sae  sae     194416 Jun 22 02:51 flink-cep-1.15.1.jar
-rw-r--r--. 1 sae  sae     484728 Jun 22 02:54 flink-connector-files-1.15.1.jar
-rw-r--r--. 1 sae  sae      95184 Jun 22 03:03 flink-csv-1.15.1.jar
-rw-r--r--. 1 sae  sae  115818049 Jun 22 03:13 flink-dist-1.15.1.jar
-rw-r--r--. 1 sae  sae     175487 Jun 22 03:05 flink-json-1.15.1.jar
-rw-r--r--. 1 sae  sae   21041716 Jun 22 03:10 flink-scala_2.12-1.15.1.jar
-rw-rw-r--. 1 sae  sae   10737871 May 12 22:45 flink-shaded-zookeeper-3.5.9.jar
-rw-r--r--. 1 root root   5381644 Jul 11 19:25 flink-sql-parquet-1.15.0.jar
-rw-r--r--. 1 sae  sae   15262738 Jun 22 03:10 
flink-table-api-java-uber-1.15.1.jar
-rw-r--r--. 1 sae  sae   36236261 Jun 22 03:10 
flink-table-planner-loader-1.15.1.jar
-rw-r--r--. 1 sae  sae    2996565 Jun 22 02:51 flink-table-runtime-1.15.1.jar
-rw-r--r--. 1 root root   2792264 Jul 11 19:28 guava-29.0-jre.jar
-rw-r--r--. 1 root root   3990042 Jul 11 19:26 hadoop-common-2.8.5.jar
-rw-rw-r--. 1 sae  sae     208006 May 12 22:15 log4j-1.2-api-2.17.1.jar
-rw-rw-r--. 1 sae  sae     301872 May 12 22:15 log4j-api-2.17.1.jar
-rw-rw-r--. 1 sae  sae    1790452 May 12 22:15 log4j-core-2.17.1.jar
-rw-rw-r--. 1 sae  sae      24279 May 12 22:15 log4j-slf4j-impl-2.17.1.jar

回复