Hi,
can you check the content of the JAR file that you are submitting? There
should be a `META-INF/services` directory with a
`org.apache.flink.table.factories.Factory` file that should list the
Parque format.
See also here:
https://ci.apache.org/projects/flink/flink-docs-master/docs/connectors/table/overview/#transform-table-connectorformat-resources
Regards,
Timo
On 06.04.21 10:25, ?????? wrote:
ref:?0?2https://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:
?0?2 ?0?2 ?0?2 ?0?2 <dependency>
?0?2 ?0?2 ?0?2 ?0?2 ?0?2 <groupId>org.apache.flink</groupId>
<artifactId>flink-parquet_2.11</artifactId>
<version>1.12.2</version>
?0?2 ?0?2 ?0?2 ?0?2 </dependency>
??????????
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>(FileSystemTableSink.java:124)
at
org.apache.flink.table.filesystem.FileSystemTableFactory.createDynamicTableSink(FileSystemTableFactory.java:85)
