Hi Simar, just to be sure, did you create a subfolder in the plugins folder where you put the jar as described here [1]?
[1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/deployment/filesystems/plugins/ On Sun, Jul 4, 2021 at 8:10 PM Singh Simarpreet (SX/EAA2) < simarpreet.si...@bosch.com> wrote: > Hi, > > > > I am facing the below exception while running the job *from Flink > Dashboard* and *from AKS Cluster* : > > Caused by: org.apache.flink.core.fs.UnsupportedFileSystemSchemeException: > Could not find a file system implementation for scheme 'wasb'. The scheme > is directly supported by Flink through the following plugin: > flink-fs-azure-hadoop. > > > > In order to connect to the Blob storage we have done the below setup: > > 1. Put the flink-azure-fs-hadoop.jar in plugins folder in AKS cluster. > > 2. In the yaml file we have put this > > fs.azure.account.key.pjmsimt1pfdbsbsa.blob.core.windows.net: > zSw+bQfhHIZsN0sJHsa8Qz4oJjNhktdwuFWHkfA3tjxgSodnniLfOQ2ZKLmFOHcme8DwWk3s0C8+2r1wzlqNmQ== > > 3. We have also tried restarting pods after yaml configurations. > > 4. Also, in code, tried writing to blob storage with stream.writeAsText > and also with StreamingFileSink.*forRowFormat *but no luck. > > > > > > I have also attached the code and error for reference. Could you please > suggest and help to get the connectivity of Flink job with Azure Blob Storage? > > Hoping to get your reply soon. > > > > Regards > > Simar > >
