[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: BOUNDED VS UNBOUNDED

runtime for UNBOUNDED data streams with no fixed set of records to process. I hope this explains it better. Israel Ekpo Lead Instructor, IzzyAcademy.com https://www.youtube.com/c/izzyacademy https://izzyacademy.com/ On Mon, Jul 25, 2022 at 9:46 PM 하지양 wrote: > Hello Again! > >

Re: [VOTE] FLIP-212: Introduce Flink Kubernetes Operator

on FLIP-212: Introduce Flink Kubernetes > > > > Operator [1] which has been discussed in [2]. > > > > > > > > The vote will be open for at least 72 hours unless there is an > > > > objection or not enough votes. > > > > > > > &

Re: [VOTE] Release 1.11.6/1.12.7/1.13.5/1.14.2, release candidate #1

ink-1460 > > 1.12: > > https://repository.apache.org/content/repositories/orgapacheflink-1462 > > 1.13: > > https://repository.apache.org/content/repositories/orgapacheflink-1459 > > 1.14: > > https://repository.apache.org/content/repositories/orgapacheflink-146

Re: [VOTE] Release 1.11.6/1.12.7/1.13.5/1.14.2, release candidate #1

.jspa?projectId=12315522=12351056 > >>>>> 1.12: > >> > https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351057 > >>>>> 1.13: > >> > https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351058 > >>>>> 1.14: > >> > https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12351059 > >>>>> [2] > >>>>> 1.11: https://dist.apache.org/repos/dist/dev/flink/flink-1.11.6-rc1/ > >>>>> 1.12: https://dist.apache.org/repos/dist/dev/flink/flink-1.12.7-rc1/ > >>>>> 1.13: https://dist.apache.org/repos/dist/dev/flink/flink-1.13.5-rc1/ > >>>>> 1.14: https://dist.apache.org/repos/dist/dev/flink/flink-1.14.2-rc1/ > >>>>> [3] https://dist.apache.org/repos/dist/release/flink/KEYS > >>>>> [4] > >>>>> 1.11: > >> https://repository.apache.org/content/repositories/orgapacheflink-1460 > >>>>> 1.12: > >> https://repository.apache.org/content/repositories/orgapacheflink-1462 > >>>>> 1.13: > >> https://repository.apache.org/content/repositories/orgapacheflink-1459 > >>>>> 1.14: > >> https://repository.apache.org/content/repositories/orgapacheflink-1461 > >>>>> [5] > >>>>> 1.11: > >> https://github.com/apache/flink/releases/tag/release-1.11.6-rc1 > >>>>> 1.12: > >> https://github.com/apache/flink/releases/tag/release-1.12.7-rc1 > >>>>> 1.13: > >> https://github.com/apache/flink/releases/tag/release-1.13.5-rc1 > >>>>> 1.14: > >> https://github.com/apache/flink/releases/tag/release-1.14.2-rc1 > >>>>> [6] https://github.com/apache/flink-web/pull/489 > -- Israel Ekpo Lead Instructor, IzzyAcademy.com https://izzyacademy.com/

[jira] [Created] (FLINK-24683) Add Support for Azure Synapse Analytics

Israel Ekpo created FLINK-24683: --- Summary: Add Support for Azure Synapse Analytics Key: FLINK-24683 URL: https://issues.apache.org/jira/browse/FLINK-24683 Project: Flink Issue Type

Re: [Discuss] Planning Flink 1.15

Thanks for the update, Joe. Looking forward to this release. On Mon, Oct 25, 2021 at 11:13 AM Johannes Moser wrote: > Hi all, > > As people have already started working on their 1.15. > contribution, we'd like to start the discussion for > the release setup. > > - Release managers: As a team

Re: [VOTE] FLIP-150: Introduce Hybrid Source

+1 (non-binding) On Thu, Jul 1, 2021 at 6:45 PM Elkhan Dadashov wrote: > +1 (non-binding) > > On 2021/07/01 05:49:44 蒋晓峰 wrote: > > Hi everyone, > > > > > > > > > > Thanks for all the feedback to Hybrid Source so far. Based on the > discussion[1] we seem to have consensus, so I would like to

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: [DISCUSS] Drop Mesos in 1.14

I am in favor of dropping the support for Mesos. In terms of the landscape for users leveraging Mesos for the kind of workloads Flink is used, I think it is on the decline. +1 from me On Tue, Jun 22, 2021 at 11:32 AM Seth Wiesman wrote: > Sorry if this is a naive question, I don't have any

Re: [DISCUSS] Adding Azure Platform Support in DataStream, Table and SQL Connectors

ed on the second one. I'm also willing to help > review your pull requests. > > What do you mean by "standalone plugins" in the context of connectors? > Would you like to contribute these connectors to the main Flink codebase, > or maintain them outside Flink but list them in flink-pa

[DISCUSS] Adding Azure Platform Support in DataStream, Table and SQL Connectors

I have opened the following issues to track new efforts to bring additional Azure Support in the following areas to the connectors ecosystem. My goal is to add the first two features [FLINK-18562] and [FLINK-18568] to the existing file system capabilities [1] and then have the other connectors

[jira] [Created] (FLINK-18568) Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink

Israel Ekpo created FLINK-18568: --- Summary: Add Support for Azure Data Lake Store Gen 2 in Streaming File Sink Key: FLINK-18568 URL: https://issues.apache.org/jira/browse/FLINK-18568 Project: Flink

[jira] [Created] (FLINK-18567) Add Support for Azure Cognitive Search DataStream Connector

Israel Ekpo created FLINK-18567: --- Summary: Add Support for Azure Cognitive Search DataStream Connector Key: FLINK-18567 URL: https://issues.apache.org/jira/browse/FLINK-18567 Project: Flink

[jira] [Created] (FLINK-18566) Add Support for Azure Cognitive Search DataStream Connector

Israel Ekpo created FLINK-18566: --- Summary: Add Support for Azure Cognitive Search DataStream Connector Key: FLINK-18566 URL: https://issues.apache.org/jira/browse/FLINK-18566 Project: Flink

[jira] [Created] (FLINK-18565) Add Support for Azure Event Grid DataStream Connector

Israel Ekpo created FLINK-18565: --- Summary: Add Support for Azure Event Grid DataStream Connector Key: FLINK-18565 URL: https://issues.apache.org/jira/browse/FLINK-18565 Project: Flink Issue

[jira] [Created] (FLINK-18564) Add Support for Azure Event Hub DataStream Connector

Israel Ekpo created FLINK-18564: --- Summary: Add Support for Azure Event Hub DataStream Connector Key: FLINK-18564 URL: https://issues.apache.org/jira/browse/FLINK-18564 Project: Flink Issue

[jira] [Created] (FLINK-18563) Add Support for Azure Cosmos DB DataStream Connector

Israel Ekpo created FLINK-18563: --- Summary: Add Support for Azure Cosmos DB DataStream Connector Key: FLINK-18563 URL: https://issues.apache.org/jira/browse/FLINK-18563 Project: Flink Issue

[jira] [Created] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

Israel Ekpo created FLINK-18562: --- Summary: Add Support for Azure Data Lake Store Gen 2 in Flink File System Key: FLINK-18562 URL: https://issues.apache.org/jira/browse/FLINK-18562 Project: Flink

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 >

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

. Similar 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

[jira] [Created] (FLINK-17989) java.lang.NoClassDefFoundError: org/apache/flink/fs/azure/common/hadoop/HadoopRecoverableWriter

Israel Ekpo created FLINK-17989: --- Summary: java.lang.NoClassDefFoundError: org/apache/flink/fs/azure/common/hadoop/HadoopRecoverableWriter Key: FLINK-17989 URL: https://issues.apache.org/jira/browse/FLINK-17989

Re: [DISCUSS] Semantics of our JIRA fields

+1 for the proposal This will bring some consistency to the process Regarding Closed vs Resolved, should we go back and switch all the Resolved issues to Closed so that is is not confusing to new people to the project in the future that may not have seen this discussion? I would recommend