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

2018-10-01 Thread Hequn Cheng (JIRA)
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

2018-10-01 Thread Rong Rong
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 s

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

2018-10-01 Thread Rong Rong
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 ass

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

2018-10-01 Thread Thomas Wozniakowski (JIRA)
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 Proj

Re: [DISCUSS] FLIP-23 Model Serving

2018-10-01 Thread Fabian Hueske
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 proposa

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

2018-10-01 Thread Fabian Hueske (JIRA)
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

2018-10-01 Thread Andrey Zagrebin (JIRA)
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

2018-10-01 Thread Aleksei Izmalkin (JIRA)
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

2018-10-01 Thread Andrey Zagrebin (JIRA)
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 Issue

Re: Request for contributor permission

2018-10-01 Thread Tzu-Li Chen
@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 ; Tz

Re: [DISCUSS] Feature freeze for Flink 1.7

2018-10-01 Thread David Anderson
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 29

回复：Request for contributor permission

2018-10-01 Thread Yun Gao
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

2018-10-01 Thread Chesnay Schepler
@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. yungao.g

Re: [DISCUSS] Dropping flink-storm?

2018-10-01 Thread Fabian Hueske
+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 deve

[DISCUSS] Improvements to the Unified SQL Connector API

2018-10-01 Thread Timo Walther
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 connectors/examp

Re: [DISCUSS] Feature freeze for Flink 1.7

2018-10-01 Thread Piotr Nowojski
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 (e.

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

2018-10-01 Thread Dawid Wysakowicz (JIRA)
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