> No FileSystem for scheme: file
It seems that your path does not work correctly, from the patch you gave, the
directly name 'test.parquet’ seems invalid.
Best,
Danny Chan
在 2020年7月11日 +0800 AM8:07,Danny Chan ,写道:
>
> It seems that your path does not work correctly, from the patch you gave, the
Hi, Leon
The exception comes from Hadoop side, looks like you missed some Hadoop
dependencies.
Hadoop is needed for Parquet, compared to add Hadoop-related dependencies
directly, it’s recommended to set HADOOP_CLASSPATH or use flink shaded hadoop
uber jar[1].
Best,
Leonard Xu
[1]https://ci
Hi,
I am trying Table API in Flink 1.11:
tEnv.executeSql("CREATE TABLE people (\n" +
"id INT,\n" +
"name STRING\n" +
") WITH (\n" +
"'connector' = 'filesystem',\n" +
"'path' = 'file:///data/test.parquet',\n" +
"'format'=