Re: Using FileSystem SQL Connector to Commit Hive Partition Exception

Hi Chenzuoli, The NoSuchMethodError seems to indicate there's a dependency conflict. What's the hadoop version you're using? And could you also check whether there are multiple hadoop jars (in different versions) in the classpath? On Wed, Apr 14, 2021 at 5:10 PM chenzuoli wrote: > Hi: > This

Re: Using FileSystem SQL Connector to Commit Hive Partition Exception

Hi: This is the log attachment:

Re: Using FileSystem SQL Connector to Commit Hive Partition Exception

Hi Chenzuoli, it seems that you are using Windows 10, you could follow this page to improve the screenshots quality:

Re: Using FileSystem SQL Connector to Commit Hive Partition Exception

Hi Chenzuoli, The pictures are unfortunately not readable for me. Cheers, Till On Wed, Apr 14, 2021 at 3:31 AM chenzuoli wrote: > Download full resolution images > Available until May 14, 2021 > >

Re: Using FileSystem SQL Connector to Commit Hive Partition Exception

Hi Chenzuoli, the exception says that Flink could not allocate enough slots. Could you share the DEBUG logs of the run with us. They should contain the reason why the allocation of further resources failed. Cheers, Till On Sun, Apr 11, 2021 at 5:59 AM chenzuoli wrote: > >

Using FileSystem SQL Connector to Commit Hive Partition Exception

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