RE: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-19 Thread Ivan Webber via user
flink operator. From: Ivan Webber Sent: Tuesday, May 16, 2023 8:01 PM To: DEROCCO, CHRISTOPHER ; Shammon FY Cc: user@flink.apache.org Subject: RE: MSI Auth to Azure Storage Account with Flink Apache Operator not working When you create your cluster you probably need to ensure the following setti

Re: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-17 Thread Surendra Singh Lilhore
shaded.hadoop3.org.apache.hadoop.fs.azurebfs.oauth2.MsiTokenProvider* > > > > > > *From:* Surendra Singh Lilhore > *Sent:* Tuesday, May 16, 2023 11:46 PM > *To:* Ivan Webber > *Cc:* DEROCCO, CHRISTOPHER ; Shammon FY ; > user@flink.apache.org > *Subject:* Re: MSI Auth t

RE: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-17 Thread DEROCCO, CHRISTOPHER
Webber Cc: DEROCCO, CHRISTOPHER ; Shammon FY ; user@flink.apache.org Subject: Re: MSI Auth to Azure Storage Account with Flink Apache Operator not working Hi DEROCCO, Flink uses shaded jars for the Hadoop Azure Storage plugin, so in order to correct the ClassNotFoundException, you need to

RE: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-17 Thread DEROCCO, CHRISTOPHER
g> Subject: [EXTERNAL] RE: MSI Auth to Azure Storage Account with Flink Apache Operator not working You don't often get email from cd9...@att.com<mailto:cd9...@att.com>. Learn why this is important<https://urldefense.com/v3/__https:/aka.ms/LearnAboutSenderIdent

Re: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-16 Thread Surendra Singh Lilhore
s somehow helpful. > > > > Best of luck, > > > > Ivan > > > > *From: *DEROCCO, CHRISTOPHER > *Sent: *Monday, May 8, 2023 3:40 PM > *To: *Shammon FY > *Cc: *user@flink.apache.org > *Subject: *[EXTERNAL] RE: MSI Auth to Azure Storage Ac

RE: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-16 Thread Ivan Webber via user
FY Sent: Friday, May 5, 2023 8:38 PM To: DEROCCO, CHRISTOPHER Cc: user@flink.apache.org Subject: Re: MSI Auth to Azure Storage Account with Flink Apache Operator not working Hi DEROCCO, I think you can check the startup command of the job on k8s to see if the jar file is in the classpath. I

RE: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-08 Thread DEROCCO, CHRISTOPHER
with writing checkpoints to Azure ADLS2gen Storage with managed service identity (MSI) authentication.? From: Shammon FY Sent: Friday, May 5, 2023 8:38 PM To: DEROCCO, CHRISTOPHER Cc: user@flink.apache.org Subject: Re: MSI Auth to Azure Storage Account with Flink Apache Operator not working

Re: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-05 Thread Shammon FY
PM > *To:* DEROCCO, CHRISTOPHER > *Cc:* user@flink.apache.org > *Subject:* Re: MSI Auth to Azure Storage Account with Flink Apache > Operator not working > > > > Hi DEROCCO, > > > > I think you need to check whether there is a hadoop-azure jar file in the > class

RE: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-05 Thread DEROCCO, CHRISTOPHER
How can I add the package to the flink job or check if it is there? From: Shammon FY Sent: Thursday, May 4, 2023 9:59 PM To: DEROCCO, CHRISTOPHER Cc: user@flink.apache.org Subject: Re: MSI Auth to Azure Storage Account with Flink Apache Operator not working Hi DEROCCO, I think you need to

Re: MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-04 Thread Shammon FY
Hi DEROCCO, I think you need to check whether there is a hadoop-azure jar file in the classpath of your flink job. From an error message '*Caused by: java.lang.ClassNotFoundException: Class org.apache.hadoop.fs.azurebfs.oauth2.MsiTokenProvider not found.*', your flink job may be missing this packa

MSI Auth to Azure Storage Account with Flink Apache Operator not working

2023-05-04 Thread DEROCCO, CHRISTOPHER
I receive the error: Caused by: java.lang.ClassNotFoundException: Class org.apache.hadoop.fs.azurebfs.oauth2.MsiTokenProvider not found. I'm using flink 1.16 running in Azure Kubernetes using the Flink Apache Kubernetes Operator. I have the following specified in the spec.flinkConfiguration: as