[FLINK-15586] BucketingSink is ignoring plugins when trying to re-instantiate the HadoopFileSystem

• Type: Bug
• Status: Reopened
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.10.0
• Component/s: Connectors / FileSystem
• Assignee: Unassigned
• Reporter: Piotr Nowojski
• Created: 14/Jan/20 14:09
• Updated: 29/Jul/21 07:37

Description

BucketingSink#createHadoopFileSystem first is loading org.apache.flink.core.fs.FileSystem through the plugin class loader (correctly), but later in the "re-instantiate" branch it's ignoring the plugin class loader/PluginManager classes altogether, which means it will be looking for non existing classes in the parent class loader.