?????? Flink 1.12.2 sql api use parquet format error

2021-04-09 Thread ??????
After change pom.xml, new error: org.apache.flink.runtime.rest.handler.RestHandlerException: Could not execute application. at org.apache.flink.runtime.webmonitor.handlers.JarRunHandler.lambda$handleRequest$1(JarRunHandler.java:108) at java.util.concurrent.CompletableFuture.uniHandle(Completa

Re: Flink 1.12.2 sql api use parquet format error

2021-04-08 Thread Timo Walther
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/connec

Flink 1.12.2 sql api use parquet format error

2021-04-06 Thread ??????
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: