[ANNOUNCE] Share your Streaming Stories with us at Current 2023

Do you have a great data streaming story to share? We want to hear from you! Speaking at Current 2023 is a great way to connect with hundreds of your peers, become more involved in the data streaming community, and have a public platform for you to share your story of the future of streaming and

Re: k8s not able to submit job from jobmanager

Your Flink versions are different Your Docker container has version 1.13.2 but it seems your job is attempting to submit with 1.14 in application mode That is the first obvious observation On Tue, Oct 5, 2021 at 5:35 AM Dhiru wrote: > *My DockerFile * > > FROM flink:1.13.2-scala_2.12-java11 >

Re: [Question] Why doesn't Flink use Calcite adapter?

Maybe this question was better addressed to the DEV list. On Fri, Jun 25, 2021 at 11:57 PM guangyuan wang wrote: > > > > I have read the design doc of the Flink planner recently. I've found the > Flink only uses Calcite as an SQL optimizer. It

Re: Flink - Pod Identity

Are you running on Azure Kubernetes Service. You should be able to do it because the identity can be mapped to the labels of the pods not necessary Flink. On Sat, Apr 3, 2021 at 6:31 AM Swagat Mishra wrote: > Hi, > > I think flink doesn't support pod identity, any plans tk achieve it in any > s

Re: Native Kubernetes deployment with GitOps

If you are just getting started, running it on Kubernetes could simplify that logistics and resources needed for getting started. It also allows you to possibly reuse infrastructure that you may already be using for other projects and purposes. If you are just getting started and just learning, t

Re: [Announce] Flink Forward Call for Proposals Extended

Thanks Seth for sharing this. I am looking forward to the event. On Fri, Jun 19, 2020 at 10:54 AM Seth Wiesman wrote: > Hi Everyone! > > > The Call for Presentations for Flink Forward has been extended until *Sunday, > June 28, 11:59 pm PST*. We know that tech conferences are not a priority > f

Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter

imilar to HadoopRecoverableWriter and S3RecoverableWriter. > > Cheers, > Till > > On Thu, May 28, 2020 at 6:00 PM Israel Ekpo wrote: > >> Hi Till, >> >> Thanks for your feedback and guidance. >> >> It seems similar work was done for S3 filesystem where

Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter

StreamingFileSink. > > Cheers, > Till > > On Thu, May 28, 2020 at 4:39 PM Israel Ekpo wrote: > >> Guowei, >> >> What do we need to do to add support for it? >> >> How do I get started on that? >> >> >> >> On Wed, May 27,

Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter

sues.apache.org/jira/browse/FLINK-17444 > Best, > Guowei > > > Israel Ekpo 于2020年5月28日周四 上午6:04写道： > >> You can assign the task to me and I will like to collaborate with someone >> to fix it. >> >> On Wed, May 27, 2020 at 5:52 PM Israel Ekpo wrote: >&g

Re: [DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter

You can assign the task to me and I will like to collaborate with someone to fix it. On Wed, May 27, 2020 at 5:52 PM Israel Ekpo wrote: > Some users are running into issues when using Azure Blob Storage for the > StreamFileSink > > https://issues.apache.org/jira/browse/FLINK-17989 &

[DISCUSS] FLINK-17989 - java.lang.NoClassDefFoundError org.apache.flink.fs.azure.common.hadoop.HadoopRecoverableWriter

Some users are running into issues when using Azure Blob Storage for the StreamFileSink https://issues.apache.org/jira/browse/FLINK-17989 The issue is because certain packages are relocated in the POM file and some classes are dropped in the final shaded jar I have attempted to comment out the r