[jira] [Created] (FLINK-10476) Change related ProcessFunction to KeyedProcessFunction in Sql/Table-api

Hequn Cheng created FLINK-10476: --- Summary: Change related ProcessFunction to KeyedProcessFunction in Sql/Table-api Key: FLINK-10476 URL: https://issues.apache.org/jira/browse/FLINK-10476 Project: Flink

Re: [DISCUSS] FLIP-23 Model Serving

Thanks for the contribution Boris!! I've been playing around with the basic model for a while back and loved it. +1 and really looking forward to having the feature merging back to Flink ML. -- Rong On Mon, Oct 1, 2018 at 7:55 AM Fabian Hueske wrote: > Hi everybody, > > The question of how to

Re: Handling burst I/O when using tumbling/sliding windows

Hi Piotrek, Thanks for the quick response. To follow up with the questions: Re 1). Yes it is causing network I/O issues on Kafka itself. Re 2a). Actually. I thought about it last weekend and I think there's a way for a work around: We directly duplicated the key extraction logic in our window

[jira] [Created] (FLINK-10475) Standalone HA - Leader election is not triggered on loss of leader

Thomas Wozniakowski created FLINK-10475: --- Summary: Standalone HA - Leader election is not triggered on loss of leader Key: FLINK-10475 URL: https://issues.apache.org/jira/browse/FLINK-10475

Re: [DISCUSS] FLIP-23 Model Serving

Hi everybody, The question of how to serve ML models in Flink applications came up in several conversations I had with Flink users in the last months. Recently, Boris approached me and he told me that he'd like to revive the efforts around FLIP-23 [1]. In the last days, Boris extended the

[jira] [Created] (FLINK-10474) Don't translate IN to JOIN with VALUES for streaming queries

Fabian Hueske created FLINK-10474: - Summary: Don't translate IN to JOIN with VALUES for streaming queries Key: FLINK-10474 URL: https://issues.apache.org/jira/browse/FLINK-10474 Project: Flink

[jira] [Created] (FLINK-10473) State TTL incremental cleanup using Heap backend key iterator

Andrey Zagrebin created FLINK-10473: --- Summary: State TTL incremental cleanup using Heap backend key iterator Key: FLINK-10473 URL: https://issues.apache.org/jira/browse/FLINK-10473 Project: Flink

[jira] [Created] (FLINK-10472) Add CBRT math function supported in Table API and SQL

Aleksei Izmalkin created FLINK-10472: Summary: Add CBRT math function supported in Table API and SQL Key: FLINK-10472 URL: https://issues.apache.org/jira/browse/FLINK-10472 Project: Flink

[jira] [Created] (FLINK-10471) State TTL cleanup using RocksDb compaction filter

Andrey Zagrebin created FLINK-10471: --- Summary: State TTL cleanup using RocksDb compaction filter Key: FLINK-10471 URL: https://issues.apache.org/jira/browse/FLINK-10471 Project: Flink

Re: Request for contributor permission

@ches...@apache.org OK, I get it. Best, tison. Yun Gao 于2018年10月1日周一 下午5:15写道： > Thanks a lot ! @Chesnay Schepler@Tzu-Li Chen : ) > > > Yours > Yun Gao > > -- > 发件人：Chesnay Schepler > 发送时间：2018年10月1日(星期一) 17:10 > 收件人：dev ;

Re: [DISCUSS] Feature freeze for Flink 1.7

What would this timing mean for the epic around state schema evolution and state migration? On Mon, Oct 1, 2018 at 10:43 AM Piotr Nowojski wrote: > Hi, > > I think that’s a good time for the release, will give us some time before > holidays season for potential bug fixes. > > Piotrek > > > On

回复：Request for contributor permission

Thanks a lot ! @Chesnay Schepler@Tzu-Li Chen : ) Yours Yun Gao -- 发件人：Chesnay Schepler 发送时间：2018年10月1日(星期一) 17:10 收件人：dev ; Tzu-Li Chen ; yungao.gy ; trohrmann ; Stephan Ewen 主　题：Re: Request for contributor permission @Yun

Re: Request for contributor permission

@Yun Gao: You now have contributor permission. @Tzu-Li Chen: Please don't ping specific people for these kind of mails as plenty of other people can resolve them. On 01.10.2018 08:27, Tzu-Li Chen wrote: Hi Gao, Welcome to Flink community! cc Till and Stephan for you. Best, tison.

Re: [DISCUSS] Dropping flink-storm?

+1 to drop it. Thanks, Fabian Am Sa., 29. Sep. 2018 um 12:05 Uhr schrieb Niels Basjes : > I would drop it. > > Niels Basjes > > On Sat, 29 Sep 2018, 10:38 Kostas Kloudas, > wrote: > > > +1 to drop it as nobody seems to be willing to maintain it and it also > > stands in the way for future

[DISCUSS] Improvements to the Unified SQL Connector API

Hi everyone, as some of you might have noticed, in the last two releases we aimed to unify SQL connectors and make them more modular. The first connectors and formats have been implemented and are usable via the SQL Client and Java/Scala/SQL APIs. However, after writing more

Re: [DISCUSS] Feature freeze for Flink 1.7

Hi, I think that’s a good time for the release, will give us some time before holidays season for potential bug fixes. Piotrek > On 29 Sep 2018, at 05:08, Steven Wu wrote: > > Please prioritize a proper long-term fix for this issue. it is a big > scalability issue for high-parallelism job

[jira] [Created] (FLINK-10470) Add method to check if pattern can produce empty matches

Dawid Wysakowicz created FLINK-10470: Summary: Add method to check if pattern can produce empty matches Key: FLINK-10470 URL: https://issues.apache.org/jira/browse/FLINK-10470 Project: Flink

Re: Request for contributor permission

Hi Gao, Welcome to Flink community! cc Till and Stephan for you. Best, tison. yungao.gy 于2018年10月1日周一 下午1:42写道： > > Hi all, > > I want to start contributing to Flink with FLINK-10469. Could someone > grant me the contributor permission? My Jira ID is gaoyunhaii and my full > name is Yun Gao.