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 is

Re: Using FileSystem SQL Connector to Commit Hive Partition Exception

Hi: This is the log attachment: https://www.icloud.com/attachment/?u=https%3A%2F%2Fcvws.icloud-content.com%2FB%2FAe5GSkj-YFuZTCZGaEu6GPihzx-7AdUBnM39Y4MbYWsiYk_NLx9zwJQQ%2F%24%7Bf%7D%3Fo%3DAlVY5QSsW5BX_oH9EoZOHG6QkCn05TIH8YH2miB0n_C5%26v%3D1%26x%3D3%26a%3DCAog36C0QwaK0BMfOhUFlqSplqI58eCIbiUgrnvfRrd

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: https://support.microsoft.com/en-us/windows/open-snipping-tool-and-take-a-screenshot-a35ac9ff-4a58-24c9-3253-f12bac9f9d44#:~:text=To%20open%20the%20Snipping%20Tool,Snip%2C%20and%20th

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: > > https://ci.apache.org

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