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