Re: java.io.StreamCorruptedException: unexpected block data

2021-04-21 Thread Jingsong Li
Hi Alokh, Maybe this is related to https://issues.apache.org/jira/browse/FLINK-20241 We can improve `SerializableConfiguration` to throw better exceptions. So the true reason may be "ClassNotFoundException" Can you check your dependencies? Like Hadoop related dependencies? Best, Jingsong On F

Re: java.io.StreamCorruptedException: unexpected block data

2021-04-16 Thread Alokh P
The flink version is 1.12.1 On Fri, Apr 16, 2021 at 1:59 PM Alokh P wrote: > Hi Community, > Facing this error when trying to query Parquet data using flink SQL Client > > Create Table command > > CREATE TABLE test( > `username` STRING, > `userid` INT) WITH ('connector' = 'filesystem', 'pat