ref: https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/formats/parquet.html


env and error:


Flink version?? 1.12.2
deployment?? standalone kubernetes session
dependency:
&nbsp; &nbsp; &nbsp; &nbsp; <dependency&gt;
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; <groupId&gt;org.apache.flink</groupId&gt;
&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; &nbsp; 
&nbsp;<artifactId&gt;flink-parquet_2.11</artifactId&gt;
&nbsp;&nbsp;&nbsp;&nbsp; &nbsp; &nbsp; &nbsp;<version&gt;1.12.2</version&gt;
&nbsp; &nbsp; &nbsp; &nbsp; </dependency&gt;



??????????
Caused by: org.apache.flink.table.api.ValidationException: Could not find any 
format factory for identifier 'parquet' in the classpath. at 
org.apache.flink.table.filesystem.FileSystemTableSink.<init&gt;(FileSystemTableSink.java:124)
 at 
org.apache.flink.table.filesystem.FileSystemTableFactory.createDynamicTableSink(FileSystemTableFactory.java:85)

Reply via email to