Using FileSystem SQL Connector to Commit Hive Partition Exception

2021-04-10 Thread chenzuoli
https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/connectors/filesystem.html Here is my code: my datastream source: ``` public static class MySource implements SourceFunction{ String

Re: Using FileSystem SQL Connector to Commit Hive Partition Exception

2021-04-14 Thread chenzuoli
%3DB0F3D90A-B949-4097-AD3F-ACE30FBE5D19%26p%3D30%26s%3Db1YldRmDMqM72hNP9DLBbOpRbOU&uk=Ir8SHK-FfM36NNDgmyiaYg&f=Images.zip&sz=42860073 > On Apr 14, 2021, at 17:06, chenzuoli wrote: > > Hi, > > Sorry for the pictures, I cannot get out the screenshots or text from the &