Re: Table API throws "No FileSystem for scheme: file" when loading local parquet

2020-07-12 Thread Danny Chan
> 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

Re: Table API throws "No FileSystem for scheme: file" when loading local parquet

2020-07-11 Thread Leonard Xu
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

Table API throws "No FileSystem for scheme: file" when loading local parquet

2020-07-10 Thread Lian Jiang
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'=