Join Us for Flink Forward Asia 2024 in Shanghai (Nov 29-30) & Jakarta (Dec 5)!

2024-09-27 Thread Xintong Song
Dear Flink Community, We are excited to share some important news with you! Flink Forward Asia 2024 is coming up with two major events: the first in Shanghai on November 29-30, and the second in Jakarta on December 5. These gatherings will focus on the latest developments, future plans, and

[jira] [Created] (FLINK-34778) look forward to adding greenplum connectors

2024-03-20 Thread Flink CDC Issue Import (Jira)
Flink CDC Issue Import created FLINK-34778: -- Summary: look forward to adding greenplum connectors Key: FLINK-34778 URL: https://issues.apache.org/jira/browse/FLINK-34778 Project: Flink

[jira] [Created] (FLINK-34779) look forward to adding dameng(dm8) connectors

2024-03-20 Thread Flink CDC Issue Import (Jira)
Flink CDC Issue Import created FLINK-34779: -- Summary: look forward to adding dameng(dm8) connectors Key: FLINK-34779 URL: https://issues.apache.org/jira/browse/FLINK-34779 Project: Flink

[jira] [Created] (FLINK-34502) Support calculating network memory for forward and rescale edge

2024-02-22 Thread Rui Fan (Jira)
Rui Fan created FLINK-34502: --- Summary: Support calculating network memory for forward and rescale edge Key: FLINK-34502 URL: https://issues.apache.org/jira/browse/FLINK-34502 Project: Flink Issue

Re: [FLIP] Forward a flip to introduce minibatch optimization for Join

2024-01-10 Thread shuai xu
Hi Leonard, Thanks for your help very much ! I have already started the discussion about FLIP-415: Introduce a new join operator to support minibatch[1]. And I’m looking forward to your feedback if you have some spare time to take a look. [1] https://cwiki.apache.org/confluence/display

Re: [FLIP] Forward a flip to introduce minibatch optimization for Join

2024-01-10 Thread Leonard Xu
Hey, shuai I’ve added wiki permission for you, looking forward your streaming join optimization. Best, Leonard

[FLIP] Forward a flip to introduce minibatch optimization for Join

2024-01-10 Thread shuai xu
Hi all, Currently, when performing cascading connections in Flink, there is a pain point of record amplification as mentioned in discussion similar to https://lists.apache.org/thread/2021fmwhtotl0okmtyc5b7tndlp3khf9, I have implemented the optimization of POC and it works. I wonder to forward a

[jira] [Created] (FLINK-33123) Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler and

2023-09-20 Thread Zhanghao Chen (Jira)
Zhanghao Chen created FLINK-33123: - Summary: Wrong dynamic replacement of partitioner from FORWARD to REBLANCE for autoscaler and adaptive scheduler and Key: FLINK-33123 URL: https://issues.apache.org/jira

[jira] [Created] (FLINK-32655) RecreateOnResetOperatorCoordinator did not forward notifyCheckpointAborted to the real OperatorCoordinator

2023-07-24 Thread Ming Li (Jira)
Ming Li created FLINK-32655: --- Summary: RecreateOnResetOperatorCoordinator did not forward notifyCheckpointAborted to the real OperatorCoordinator Key: FLINK-32655 URL: https://issues.apache.org/jira/browse/FLINK-32655

Call for Presentations: Flink Forward Seattle 2023

2023-06-08 Thread Jing Ge
Dear Flink developers & users, We hope this email finds you well. We are excited to announce the Call for Presentations for the upcoming Flink Forward Seattle 2023, the premier event dedicated to Apache Flink and stream processing technologies. As a prominent figure in the field, we invite yo

[jira] [Created] (FLINK-30638) Operator doesn't forward allowNonRestoredState flag

2023-01-11 Thread Alexis Sarda-Espinosa (Jira)
Alexis Sarda-Espinosa created FLINK-30638: - Summary: Operator doesn't forward allowNonRestoredState flag Key: FLINK-30638 URL: https://issues.apache.org/jira/browse/FLINK-30638 Project:

Re: Flink Forward Session Question

2023-01-02 Thread Márton Balassi
Hi Rion, Unlike the previous Flink Forwards to the best of my knowledge the latest edition was not uploaded to YouTube. It might make sense to reach out to the authors directly. On Sat, Dec 31, 2022 at 5:35 PM Rion Williams wrote: > Hey Flinkers, > > Firstly, early Happy New Year’s to everyone

[jira] [Created] (FLINK-28480) Forward timeControllerExecution time as histogram for JOSDK Metrics interface

2022-07-10 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28480: -- Summary: Forward timeControllerExecution time as histogram for JOSDK Metrics interface Key: FLINK-28480 URL: https://issues.apache.org/jira/browse/FLINK-28480 Project

[REMINDER] Final Call for Presentations for Flink Forward San Francisco 2022

2022-05-06 Thread Timo Walther
restrictions, please let us know in the form. We will offer a limited number of slots for pre-recorded/remote Q&A talks to not exclude anyone. https://www.flink-forward.org/sf-2022/call-for-presentations In any case, it would be great to meet each other again! Looking forward to the e

[jira] [Created] (FLINK-27493) Forward all numeric Kafka metrics to Flink's metrics system

2022-05-05 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-27493: --- Summary: Forward all numeric Kafka metrics to Flink's metrics system Key: FLINK-27493 URL: https://issues.apache.org/jira/browse/FLINK-27493 Project:

[ANNOUNCE] Call for Presentations is open for Flink Forward San Francisco 2022 in-person!

2022-03-22 Thread Timo Walther
Hi everyone, We’re very excited to announce our Call for Presentations for Flink Forward San Francisco 2022! If you have an inspiring Apache Flink use case, real-world application, or best practice, Flink Forward is the platform for you to share your experiences. https://www.flink

[jira] [Created] (FLINK-26098) TableAPI does not forward idleness configuration from DataStream

2022-02-12 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-26098: - Summary: TableAPI does not forward idleness configuration from DataStream Key: FLINK-26098 URL: https://issues.apache.org/jira/browse/FLINK-26098 Project: Flink

Re: [DISCUSS] FLIP-207: Flink backward and forward compatibility

2021-12-31 Thread Jing Ge
To be honest, I hope it could be good enough if Flink > > could only provide backward compatibility, which is easier than providing > > forward compatibility described in the proposal. That is also one of the > > reasons why I started this discussion. If, after the discussion,

Re: [DISCUSS] FLIP-207: Flink backward and forward compatibility

2021-12-29 Thread Thomas Weise
te: > > Hi Piotrek, > > thanks for asking. To be honest, I hope it could be good enough if Flink > could only provide backward compatibility, which is easier than providing > forward compatibility described in the proposal. That is also one of the > reasons why I started this discu

Re: [DISCUSS] FLIP-207: Flink backward and forward compatibility

2021-12-29 Thread Jing Ge
Hi Piotrek, thanks for asking. To be honest, I hope it could be good enough if Flink could only provide backward compatibility, which is easier than providing forward compatibility described in the proposal. That is also one of the reasons why I started this discussion. If, after the discussion

Re: [DISCUSS] FLIP-207: Flink backward and forward compatibility

2021-12-29 Thread Piotr Nowojski
Hi Jink, I haven't yet fully reviewed the FLIP document, but I wanted to clarify something. > Flink Forward Compatibility > Based on the previous clarification, Flink forward compatibility should mean that Flink jobs or ecosystems like external connectors/formats built with newer >

[DISCUSS] FLIP-207: Flink backward and forward compatibility

2021-12-29 Thread Jing Ge
Hi everyone, with great interest I have read all discussions [1][2][3] w.r.t. the (API?) compatibility issues. The feedback coming from the Flink user's point of view is very valuable. Many thanks for it. In these discussions, there were many explanations that talked about backward and fo

[jira] [Created] (FLINK-25046) Convert forward edge to rescale when using adapive batch scheduler

2021-11-24 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-25046: -- Summary: Convert forward edge to rescale when using adapive batch scheduler Key: FLINK-25046 URL: https://issues.apache.org/jira/browse/FLINK-25046 Project: Flink

One week until Flink Forward! -- Info & special announcements

2021-10-20 Thread Caito Scherr
Hi Everyone, We have just one week before Flink Forward Global 2021!! If you (or a friend) still need to register, you can do so here <https://hopin.com/events/flink-forward-global-2021> for free. Since we’re virtual, you can join from anywhere in the world. I am excited to announce th

[jira] [Created] (FLINK-24488) KafkaRecordSerializationSchemaBuilder does not forward timestamp

2021-10-08 Thread Fabian Paul (Jira)
Fabian Paul created FLINK-24488: --- Summary: KafkaRecordSerializationSchemaBuilder does not forward timestamp Key: FLINK-24488 URL: https://issues.apache.org/jira/browse/FLINK-24488 Project: Flink

[jira] [Created] (FLINK-24255) Test Environment / Mini Cluster do not forward configuration.

2021-09-10 Thread Stephan Ewen (Jira)
Stephan Ewen created FLINK-24255: Summary: Test Environment / Mini Cluster do not forward configuration. Key: FLINK-24255 URL: https://issues.apache.org/jira/browse/FLINK-24255 Project: Flink

[jira] [Created] (FLINK-24010) HybridSourceReader needs to forward checkpoint notifications

2021-08-26 Thread Thomas Weise (Jira)
Thomas Weise created FLINK-24010: Summary: HybridSourceReader needs to forward checkpoint notifications Key: FLINK-24010 URL: https://issues.apache.org/jira/browse/FLINK-24010 Project: Flink

[jira] [Created] (FLINK-21441) FlinkKinesisProducer does not forward custom endpoint

2021-02-22 Thread Jira
Ingo Bürk created FLINK-21441: - Summary: FlinkKinesisProducer does not forward custom endpoint Key: FLINK-21441 URL: https://issues.apache.org/jira/browse/FLINK-21441 Project: Flink Issue Type

[Announce] Flink Forward Global Is Just Around the Corner

2020-10-09 Thread Seth Wiesman
Hi Everyone, Flink Forward Global is just around the corner - October 19th to the 22nd - and our amazing line up of keynotes has been announced. - Peter Chalif from Citi will explore how Apache Flink has been fundamentally changing Big Data in the financial services industry - Ricky

[jira] [Created] (FLINK-19241) Forward ClusterEntrypoint ioExecutor to ResourceManager

2020-09-15 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-19241: -- Summary: Forward ClusterEntrypoint ioExecutor to ResourceManager Key: FLINK-19241 URL: https://issues.apache.org/jira/browse/FLINK-19241 Project: Flink

[jira] [Created] (FLINK-19000) Forward JobStatus.INITIALIZING timestamp to ExecutionGraph

2020-08-19 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-19000: -- Summary: Forward JobStatus.INITIALIZING timestamp to ExecutionGraph Key: FLINK-19000 URL: https://issues.apache.org/jira/browse/FLINK-19000 Project: Flink

[Announce] Flink Forward Global Program is now Live

2020-08-13 Thread Seth Wiesman
Hi Everyone *The Flink Forward Global 2020 program is now online* and with 2 full days of exciting Apache Flink content, curated by our program committee[1]! Join us on October 21-22 to learn more about the newest technology updates, and hear use cases from Intel, Razorpay, Workday, Microsoft

Re: [Announce] Flink Forward Global Lineup Released

2020-08-03 Thread Seth Wiesman
+ link https://www.flink-forward.org/global-2020/speakers On Mon, Aug 3, 2020 at 11:25 AM Seth Wiesman wrote: > Hi everyone! > > I'm very excited to announce that the speaker lineup for Flink Forward > Global has been released. This is a fully online conference on October &g

[Announce] Flink Forward Global Lineup Released

2020-08-03 Thread Seth Wiesman
Hi everyone! I'm very excited to announce that the speaker lineup for Flink Forward Global has been released. This is a fully online conference on October 21-22 and tickets are free. The lineup includes 45+ speakers from the companies like of Spotify, AWS, Netflix, Houzz, Workday hear their

[jira] [Created] (FLINK-18658) MiniClusterResource does not forward RpcServiceSharing setting

2020-07-21 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-18658: Summary: MiniClusterResource does not forward RpcServiceSharing setting Key: FLINK-18658 URL: https://issues.apache.org/jira/browse/FLINK-18658 Project

Re: [Announce] Flink Forward Call for Proposals Extended

2020-06-24 Thread Seth Wiesman
As a reminder, the CfP for Flink Forward is open until this Sunday, June 28th. If you've never spoken at a conference before and are thinking about submitting, out amazing event manager Laura just wrote an article on dev.to about why virtual conferences are the best way to get started. [1]

Re: [Announce] Flink Forward Call for Proposals Extended

2020-06-19 Thread Israel Ekpo
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

[Announce] Flink Forward Call for Proposals Extended

2020-06-19 Thread Seth Wiesman
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 for everyone at this moment, so we wanted to ensure everyone has time to work on their ideas. As a reminder, Flink Forward Global

Re: [ANNOUNCE] Flink Forward San Francisco 2020 Program is Live

2020-02-14 Thread Fabian Hueske
code: FFSF20-MailingList * If you are an Apache committer (for any project), we offer a *free* conference pass if you register with your Apache email address and the discount code: FFSF20-ApacheCommitter Have a nice weekend, Fabian [1] https://events.evolutionaryevents.com/flink-forward-sf-2020 Am

[ANNOUNCE] Flink Forward San Francisco 2020 Program is Live

2020-02-14 Thread Fabian Hueske
Hi everyone, We announced the program of Flink Forward San Francisco 2020. The conference takes place at the Hyatt Regency in San Francisco from March 23rd to 25th. On the first day we offer four training sessions [1]: * Apache Flink Developer Training * Apache Flink Runtime & Operat

[ANNOUNCE] Community Discounts for Flink Forward SF 2020 Registrations

2020-01-30 Thread Fabian Hueske
Hi everyone, The registration for Flink Forward SF 2020 is open now! Flink Forward San Francisco 2020 will take place from March 23rd to 25th. The conference will start with one day of training and continue with two days of keynotes and talks. We would like to invite you to join the Apache Flink

[ANNOUNCE] Flink Forward San Francisco 2020 Call for Presentation extended!

2020-01-13 Thread Fabian Hueske
Hi everyone, We know some of you only came back from holidays last week. To give you more time to submit a talk, we decided to extend the Call for Presentations for Flink Forward San Francisco 2020 until Sunday January 19th. The conference takes place on March 23-25 with two days of talks and

[ANNOUNCE] Flink Forward SF Call for Presentation closing soon!

2020-01-06 Thread Fabian Hueske
Hi all, First of all, Happy New Year to everyone! Many of you probably didn't spent the holidays thinking a lot about Flink. Now, however, is the right time to focus again and decide which talk(s) to submit for Flink Forward San Francisco because the Call for Presentations is closing this S

Flink Forward North America 2020 - Call for Presentations open until January 12th, 2020

2019-11-20 Thread Fabian Hueske
Hi all, Flink Forward North America returns to San Francisco on March 23-25, 2020. For the first time in North America, the conference will feature two days of talks and one day of training. We are happy to announce that the Call for Presentations is open! If you'd like to give a talk and

[jira] [Created] (FLINK-14744) Neighboring vertex should be chained if ship strategy is FORWARD or NONE

2019-11-13 Thread Jiayi Liao (Jira)
Jiayi Liao created FLINK-14744: -- Summary: Neighboring vertex should be chained if ship strategy is FORWARD or NONE Key: FLINK-14744 URL: https://issues.apache.org/jira/browse/FLINK-14744 Project: Flink

[jira] [Created] (FLINK-14327) Getting "Could not forward element to next operator" error

2019-10-04 Thread ASK5 (Jira)
ASK5 created FLINK-14327: Summary: Getting "Could not forward element to next operator" error Key: FLINK-14327 URL: https://issues.apache.org/jira/browse/FLINK-14327 Project: Flink Issue

[jira] [Created] (FLINK-14251) Add FutureUtils#forward utility

2019-09-27 Thread Till Rohrmann (Jira)
Till Rohrmann created FLINK-14251: - Summary: Add FutureUtils#forward utility Key: FLINK-14251 URL: https://issues.apache.org/jira/browse/FLINK-14251 Project: Flink Issue Type: Improvement

[ANNOUNCE] Flink Forward training registration closes on September 30th

2019-09-05 Thread Fabian Hueske
Hi all, The registration for the Flink Forward Europe training sessions closes in four weeks. The training takes place in Berlin at October 7th and is followed by two days of talks by speakers from companies like Airbus, Goldman Sachs, Netflix, Pinterest, and Workday [1]. The following four

[ANNOUNCE] The Program of Flink Forward EU 2019 is live

2019-07-24 Thread Fabian Hueske
Hi everyone, I'm happy to announce the program of the Flink Forward EU 2019 conference. The conference takes place in the Berlin Congress Center (bcc) from October 7th to 9th. On the first day, we'll have four training sessions [1]: * Apache Flink Developer Training * Apache Flink

Re: Flink Forward Europe 2019 - Call for Presentations open until 17th May

2019-05-20 Thread Oytun Tez
he weekend, I should be ready to submit CFP. --- Oytun Tez *M O T A W O R D* The World's Fastest Human Translation Platform. oy...@motaword.com — www.motaword.com On Fri, May 17, 2019 at 11:02 AM Robert Metzger wrote: > Hey all, > > Short update on the Flink Forward Call For P

Re: Flink Forward Europe 2019 - Call for Presentations open until 17th May

2019-05-17 Thread Robert Metzger
Hey all, Short update on the Flink Forward Call For Presentations: We've extended the submission deadline till May 31 ... so there's more time to finish the talk abstracts. Also, the organizers are now able to cover travel costs for speakers in cases where an employer can not cover t

Re: Flink Forward Europe 2019 - Call for Presentations open until 17th May

2019-05-10 Thread Fabian Hueske
Hi Tim, Thanks for submitting a talk! This sounds like a good and interesting use case to me. Machine learning on streaming data is definitely a relevant and interesting topic for Flink Forward! Best, Fabian Am Mo., 6. Mai 2019 um 19:52 Uhr schrieb Tim Frey : > Hi All, > > Sounds in

AW: Flink Forward Europe 2019 - Call for Presentations open until 17th May

2019-05-06 Thread Tim Frey
: Flink Forward Europe 2019 - Call for Presentations open until 17th May Thanks for announcing the Call for Presentations here! Since the deadline is approaching, I wanted to bump up this thread to remind everybody to submit talks! Please reach out to me or Fabian directly if you have any questions

Re: Flink Forward Europe 2019 - Call for Presentations open until 17th May

2019-05-06 Thread Robert Metzger
Hueske wrote: > Hi all, > > Flink Forward Europe returns to Berlin on October 7-9th, 2019. > We are happy to announce that the Call for Presentations is open! > > Please submit a proposal if you'd like to present your Apache Flink > experience, best practices, new featu

Flink Forward Europe 2019 - Call for Presentations open until 17th May

2019-04-11 Thread Fabian Hueske
Hi all, Flink Forward Europe returns to Berlin on October 7-9th, 2019. We are happy to announce that the Call for Presentations is open! Please submit a proposal if you'd like to present your Apache Flink experience, best practices, new features, or use cases in front of an internat

Re: [REMINDER] Flink Forward San Francisco in a few days

2019-03-21 Thread Robert Metzger
o reach out to me directly if you have any questions! I'm looking forward to see as many Apache committers as possible at the conference, to discuss potential inter-project collaboration, learn from each other, ... On Wed, Mar 20, 2019 at 11:03 AM Fabian Hueske wrote: > Hi everyone, >

[REMINDER] Flink Forward San Francisco in a few days

2019-03-20 Thread Fabian Hueske
Hi everyone, *Flink Forward San Francisco 2019 will take place in a few days on April 1st and 2nd.* If you haven't done so already and are planning to attend, you should register soon at: -> https://sf-2019.flink-forward.org/register Don't forget to use the 25% discount code *Mai

Re: Program of Flink Forward San Francisco 2019 announced

2019-02-12 Thread Fabian Hueske
Am Di., 12. Feb. 2019 um 16:26 Uhr schrieb Fabian Hueske : > Hi everyone, > > We announced the program of Flink Forward San Francisco 2019. > The conference takes place at the Hotel Nikko in San Francisco on April > 1st and 2nd. > > On the first day we offer three

Program of Flink Forward San Francisco 2019 announced

2019-02-12 Thread Fabian Hueske
Hi everyone, We announced the program of Flink Forward San Francisco 2019. The conference takes place at the Hotel Nikko in San Francisco on April 1st and 2nd. On the first day we offer three training sessions [1]: * Introduction to Streaming with Apache Flink * Analyzing Streaming Data with

[ANNOUNCE] Call for Presentations Extended for Flink Forward San Francisco 2019

2018-12-01 Thread Fabian Hueske
featured speakers from AirBnb, Netflix, Uber and others — why not be in there too? http://flink-forward.org/sf-2019/call-for-presentations-submit-talk/ Tell your coworkers and friends so they can also share their Flink story! Looking forward to hearing your ideas, Fabian Program Committee Chair

[ANNOUNCE] Flink Forward San Francisco Call for Presentations closes soon

2018-11-20 Thread Fabian Hueske
Hi Everyone, Flink Forward San Francisco will *take place on April 1st and 2nd 2019*. Flink Forward is a community conference organized by data Artisans and gathers many members of the Flink community, including users, contributors, and committers. It is the perfect event to get in touch and

[ANNOUNCE] Flink Forward San Francisco 2019 - Call for Presentations is now open

2018-10-24 Thread Till Rohrmann
Hi everybody, the Call for Presentations for Flink Forward San Francisco 2019 is now open! Apply by November 30 to share your compelling Flink use case, best practices, and latest developments with the community on April 1-2 in San Francisco, CA. Submit your proposal: https://flink-forward.org

[jira] [Created] (FLINK-10423) Forward RocksDB memory metrics to Flink metrics reporter

2018-09-25 Thread Seth Wiesman (JIRA)
Seth Wiesman created FLINK-10423: Summary: Forward RocksDB memory metrics to Flink metrics reporter Key: FLINK-10423 URL: https://issues.apache.org/jira/browse/FLINK-10423 Project: Flink

[jira] [Created] (FLINK-10293) RemoteStreamEnvironment does not forward port to RestClusterClient

2018-09-06 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-10293: Summary: RemoteStreamEnvironment does not forward port to RestClusterClient Key: FLINK-10293 URL: https://issues.apache.org/jira/browse/FLINK-10293 Project

[ANNOUNCE] Program for Flink Forward Berlin 2018 has been announced

2018-07-17 Thread Fabian Hueske
Hi everyone, I'd like to announce the program for Flink Forward Berlin 2018. The program committee [1] assembled a program of about 50 talks on use cases, operations, ecosystem, tech deep dive, and research topics. The conference will host speakers from Airbnb, Amazon, Google, ING,

[ANNOUNCE] Registration for Flink Forward Berlin is open

2018-06-14 Thread Fabian Hueske
Hi everyone, *Flink Forward Berlin 2018 will take place from September 3rd to 5th.* The conference will start with one day of training and continue with two days of keynotes and talks. *The registration for Flink Forward Berlin 2018 is now open!* A limited amount of early-bird passes is

[ANNOUNCE] Flink Forward Berlin 2018 - Call for Presentations extended until June 11

2018-06-01 Thread Fabian Hueske
Hi everybody, Due to popular demand, we've extended the Call for Presentations for Flink Forward Berlin 2018 by one week. The call will close on *Monday, June 11* (11:59pm CEST). Please submit a proposal to present your Flink and Stream Processing use case, experiences, and best practic

[jira] [Created] (FLINK-9493) Forward exception when releasing a TaskManager at the SlotPool

2018-06-01 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-9493: Summary: Forward exception when releasing a TaskManager at the SlotPool Key: FLINK-9493 URL: https://issues.apache.org/jira/browse/FLINK-9493 Project: Flink

[ANNOUNCE] Final Reminder - Call for Presentations - Flink Forward Berlin 2018

2018-05-28 Thread Fabian Hueske
Hi all, This is the final reminder for the call for presentations for Flink Forward Berlin 2018. *The call closes in 7 days* (June 4, 11:59 PM CEST). Submit your talk and get to present your Apache Flink and stream processing ideas, experiences, use cases, and best practices on September 4-5 in

Flink Forward Berlin 2018 - Call for Presentations open until 4th June

2018-05-18 Thread Fabian Hueske
Hi all, Flink Forward returns to Berlin on September 3-5, 2018. We are happy to announce the Call for Presentations is now open! Please submit a proposal if you'd like to present your Apache Flink experience, best practices or use case in front of an international audience of highly skille

Subject: Last chance to register for Flink Forward SF (April 10). Get 25% discount

2018-03-29 Thread Stephan Ewen
Hi all! There are still some spots left to attend Flink Forward San Francisco, so sign up soon before registration closes. Use this promo code to get 25% off: MailingListFFSF The 1-day conference takes place on Tuesday, April 10 in downtown SF. We have a great lineup of speakers from companies

Flink Forward San Francisco 2018 - Call for Presentation is open

2017-11-30 Thread Fabian Hueske
Dear Flink community, The Call for Presentations for Flink Forward San Francisco 2018 is now open! Share your experiences and best practices in stream processing, real-time analytics, and managing mission-critical Flink deployments in production. We’re happy to receive your talk ideas until

[jira] [Created] (FLINK-7686) Add Flink Forward Berlin 2017 conference slides to the flink website

2017-09-25 Thread Hai Zhou_UTC+8 (JIRA)
Hai Zhou_UTC+8 created FLINK-7686: - Summary: Add Flink Forward Berlin 2017 conference slides to the flink website Key: FLINK-7686 URL: https://issues.apache.org/jira/browse/FLINK-7686 Project: Flink

Re: [ANNOUNCE] Flink Forward Berlin (11-13 Sep 2017) Call for Submissions is open now

2017-08-20 Thread Robert Metzger
Dear Flink Community, I'd like to quickly bring your attention to Flink Forward Berlin <https://berlin.flink-forward.org/> again. The conference is happening in Berlin, Germany from September 11-13. There's a pretty impressive list of talks, including - keynotes from Alibaba, da

[jira] [Created] (FLINK-6776) Use skip instead of seek for small forward repositioning in DFS streams

2017-05-30 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6776: - Summary: Use skip instead of seek for small forward repositioning in DFS streams Key: FLINK-6776 URL: https://issues.apache.org/jira/browse/FLINK-6776 Project

[ANNOUNCE] Flink Forward Berlin (11-13 Sep 2017) Call for Submissions is open now

2017-05-30 Thread Robert Metzger
Dear Flink Community, The Call for Submissions for Flink Forward Berlin 2017 is open now! Since we believe in collaboration, participation and exchange of ideas, we are inviting the Flink community to submit a session. Share your knowledge, applications, use cases and best practices and shape

[ANNOUNCE] Flink Forward San Francisco 10-11 Apr 2017 community discount codes

2017-03-24 Thread Robert Metzger
Dear Flink community, I would like to bring Flink Forward San Francisco to your attention. After hosting Flink Forward for two years in Berlin, Germany, we decided to bring it to the US west coast as well. Check out this very nice video summary from last year's conference in Berlin:

[jira] [Created] (FLINK-6118) Chained operators forward watermark without checking

2017-03-19 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-6118: --- Summary: Chained operators forward watermark without checking Key: FLINK-6118 URL: https://issues.apache.org/jira/browse/FLINK-6118 Project: Flink

RE: TopSpeedWindowing - in error: Could not forward element to next operator

2016-11-07 Thread Ovidiu Cristian Marcu
Thank you, I will check this fix in my environment. Best, Ovidiu -Original Message- From: Aljoscha Krettek [mailto:aljos...@apache.org] Sent: Friday, October 21, 2016 5:47 PM To: dev@flink.apache.org Subject: Re: TopSpeedWindowing - in error: Could not forward element to next operator

Re: TopSpeedWindowing - in error: Could not forward element to next operator

2016-10-21 Thread Aljoscha Krettek
t; Ovidiu > > -Original Message- > From: Till Rohrmann [mailto:trohrm...@apache.org] > Sent: Friday, October 21, 2016 2:09 PM > To: dev@flink.apache.org > Subject: Re: TopSpeedWindowing - in error: Could not forward element to > next operator > > Hi Ovidiu, >

RE: TopSpeedWindowing - in error: Could not forward element to next operator

2016-10-21 Thread Ovidiu Cristian Marcu
ginal Message- From: Till Rohrmann [mailto:trohrm...@apache.org] Sent: Friday, October 21, 2016 2:09 PM To: dev@flink.apache.org Subject: Re: TopSpeedWindowing - in error: Could not forward element to next operator Hi Ovidiu, which version of Flink are you using? Cheers, Till On Thu, Oct 20,

Re: TopSpeedWindowing - in error: Could not forward element to next operator

2016-10-21 Thread Till Rohrmann
mples.windowing. > TopSpeedWindowing > With default configuration I have no errors. > > When I change the state backend with RocksDB I receive this error: > > java.lang.RuntimeException: Could not forward element to next operator > at org.apache.flink.s

[jira] [Created] (FLINK-4871) Add memory calculation for TaskManagers and forward MetricRegistry

2016-10-20 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-4871: Summary: Add memory calculation for TaskManagers and forward MetricRegistry Key: FLINK-4871 URL: https://issues.apache.org/jira/browse/FLINK-4871 Project: Flink

TopSpeedWindowing - in error: Could not forward element to next operator

2016-10-20 Thread Ovidiu Cristian Marcu
forward element to next operator at org.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.collect(OperatorChain.java:388) at org.apache.flink.streaming.runtime.tasks.OperatorChain$ChainingOutput.collect(OperatorChain.java:1) at

[jira] [Created] (FLINK-4569) JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread.

2016-09-02 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-4569: - Summary: JobRetrievalITCase.testJobRetrieval() does not forward exceptions to parent thread. Key: FLINK-4569 URL: https://issues.apache.org/jira/browse/FLINK-4569

[ANNOUNCE] Flink Forward 2016: First round of speakers and sessions is out

2016-07-25 Thread Kostas Tzoumas
Hi everyone, I wanted to share this with the community: we have announced the first round of speakers and sessions of Flink Forward 2016, and it looks amazing! Check it out here: http://flink-forward.org/program/sessions/ This year we have a great mix of use case talks (e.g., by Netflix

Re: forward()

2016-06-27 Thread Till Rohrmann
Hi, > > > > I was reading a bit of code about partitioning and I have two questions > > about the forward() method of DataStream: > > > > 1) I was before under the impression that forwarding means sending > > records between operators with same parallelism always

Re: forward()

2016-06-27 Thread Aljoscha Krettek
un 2016 at 01:57 Marius Melzer wrote: > Hi, > > I was reading a bit of code about partitioning and I have two questions > about the forward() method of DataStream: > > 1) I was before under the impression that forwarding means sending > records between operators with same para

forward()

2016-06-26 Thread Marius Melzer
Hi, I was reading a bit of code about partitioning and I have two questions about the forward() method of DataStream: 1) I was before under the impression that forwarding means sending records between operators with same parallelism always from partition 1 to 1, 2 to 2 etc. But this doesn't

[jira] [Created] (FLINK-3850) Add forward field annotations to DataSet operators generated by the Table API

2016-04-28 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-3850: Summary: Add forward field annotations to DataSet operators generated by the Table API Key: FLINK-3850 URL: https://issues.apache.org/jira/browse/FLINK-3850 Project

[jira] [Created] (FLINK-3684) CEP operator does not forward watermarks properly

2016-03-31 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-3684: Summary: CEP operator does not forward watermarks properly Key: FLINK-3684 URL: https://issues.apache.org/jira/browse/FLINK-3684 Project: Flink Issue Type

[jira] [Created] (FLINK-3240) Remove or document DataStream(.global|.forward)

2016-01-15 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-3240: - Summary: Remove or document DataStream(.global|.forward) Key: FLINK-3240 URL: https://issues.apache.org/jira/browse/FLINK-3240 Project: Flink Issue Type

Volunteers needed for Flink Forward 2015 (and they get a free ticket)

2015-09-07 Thread Kostas Tzoumas
Hi folks, The Flink Forward 2015 organizers are looking for volunteers (and they are offering free tickets in exchange). Sign up here if you are interested (or send me an email): http://flink-forward.org/?page_id=495 Best, Kostas

[ANNOUNCE] Flink Forward 2015 program is online

2015-08-25 Thread Kostas Tzoumas
Hi everyone, Just a shoutout that we have posted the program of Flink Forward 2015 here: http://flink-forward.org/?post_type=day You can expect few changes here and there, but the majority of the talks is in. Thanks again to the speakers and the reviewers! If you have not registered yet, now

Re: Flink Forward webpage down

2015-08-14 Thread Gábor Gévay
It works for me now too. Best regards, Gabor 2015-08-14 16:10 GMT+02:00 Chiwan Park : > Currently, the site looks okay. > > Regards, > Chiwan Park > > >> On Aug 14, 2015, at 6:05 PM, Gábor Gévay wrote: >> >> Hello, >> >> I would like to subm

Re: Flink Forward webpage down

2015-08-14 Thread Chiwan Park
Currently, the site looks okay. Regards, Chiwan Park > On Aug 14, 2015, at 6:05 PM, Gábor Gévay wrote: > > Hello, > > I would like to submit an abstract to Flink Forward, but the webpage > of the conference (flink-forward.org) seems to be down. It prints > "Err

Flink Forward webpage down

2015-08-14 Thread Gábor Gévay
Hello, I would like to submit an abstract to Flink Forward, but the webpage of the conference (flink-forward.org) seems to be down. It prints "Error establishing a database connection" for me. It worked yesterday. Best regards, Gabor

[jira] [Created] (FLINK-2295) TwoInput Task do not react to/forward checkpoint barriers

2015-06-30 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-2295: --- Summary: TwoInput Task do not react to/forward checkpoint barriers Key: FLINK-2295 URL: https://issues.apache.org/jira/browse/FLINK-2295 Project: Flink

[jira] [Created] (FLINK-1985) Streaming does not correctly forward ExecutionConfig to runtime

2015-05-07 Thread Aljoscha Krettek (JIRA)
Aljoscha Krettek created FLINK-1985: --- Summary: Streaming does not correctly forward ExecutionConfig to runtime Key: FLINK-1985 URL: https://issues.apache.org/jira/browse/FLINK-1985 Project: Flink

Re: Flink Forward 2015

2015-04-08 Thread Maximilian Michels
Saved the date! This sounds very exciting. Looking forward to hearing a lot of nice talks and meeting a lot of great people! On Tue, Apr 7, 2015 at 2:24 PM, Kostas Tzoumas wrote: > Hi everyone, > > The folks at data Artisans and the Berlin Big Data Center are organizing > the fi

  1   2   >