[jira] [Created] (FLINK-6978) Add documentation for Register User-Defined Functions.

sunjincheng created FLINK-6978: -- Summary: Add documentation for Register User-Defined Functions. Key: FLINK-6978 URL: https://issues.apache.org/jira/browse/FLINK-6978 Project: Flink Issue Type:

Re: Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congratulations Shaoxuan! 2017-06-22 hzyuemeng1 发件人：Jark Wu 发送时间：2017-06-22 11:21 主题：Re: [ANNOUNCE] New Flink committer Shaoxuan Wang 收件人："dev" 抄送： Congratulations Shaoxuan! Regards, Jark 2017-06-22 11:09 GMT+08:00 JingsongLee

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congratulations Shaoxuan! Regards, Jark 2017-06-22 11:09 GMT+08:00 JingsongLee : > Congrats! > Best, Jingsong Lee > --From:Andrew > Psaltis Time:2017 Jun 22 (Thu) 11:06To:dev < >

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congrats! Best, Jingsong Lee --From:Andrew Psaltis Time:2017 Jun 22 (Thu) 11:06To:dev Subject:Re: [ANNOUNCE] New Flink committer Shaoxuan Wang Congrats Shaoxuan! On Wed, Jun 21, 2017 

Re: [ANNOUNCE] New committer: Dawid Wysakowicz

Congratulations Dawid! On Wed, Jun 21, 2017 at 10:15 PM, Haohui Mai wrote: > Congrats! > On Thu, Jun 22, 2017 at 5:51 AM Stavros Kontopoulos < > st.kontopou...@gmail.com> wrote: > > > Congratulations Dawid! > > > > On Tue, Jun 20, 2017 at 12:06 PM, Vasudevan, Ramkrishna S <

[jira] [Created] (FLINK-6977) Add MD5/SHA1/SHA2 supported in TableAPI

sunjincheng created FLINK-6977: -- Summary: Add MD5/SHA1/SHA2 supported in TableAPI Key: FLINK-6977 URL: https://issues.apache.org/jira/browse/FLINK-6977 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6975) Add CONCAT/CONCAT_WS supported in TableAPI

sunjincheng created FLINK-6975: -- Summary: Add CONCAT/CONCAT_WS supported in TableAPI Key: FLINK-6975 URL: https://issues.apache.org/jira/browse/FLINK-6975 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congrats! Thanks, Zhuoluo  > 在 2017年6月22日，上午10:14，Haohui Mai 写道： > > Congrats! > On Thu, Jun 22, 2017 at 9:58 AM SHI Xiaogang wrote: > >> Congrats, Shaoxuan >> >> Regards, >> Xiaogang >> >> 2017-06-22 9:08 GMT+08:00 jincheng sun

[jira] [Created] (FLINK-6974) Add BIN supported in TableAPI

sunjincheng created FLINK-6974: -- Summary: Add BIN supported in TableAPI Key: FLINK-6974 URL: https://issues.apache.org/jira/browse/FLINK-6974 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6973) Add L/RPAD supported in TableAPI

sunjincheng created FLINK-6973: -- Summary: Add L/RPAD supported in TableAPI Key: FLINK-6973 URL: https://issues.apache.org/jira/browse/FLINK-6973 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-6972) Flink REPL api

Praveen Kanamarlapudi created FLINK-6972: Summary: Flink REPL api Key: FLINK-6972 URL: https://issues.apache.org/jira/browse/FLINK-6972 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congrats! On Thu, Jun 22, 2017 at 9:58 AM SHI Xiaogang wrote: > Congrats, Shaoxuan > > Regards, > Xiaogang > > 2017-06-22 9:08 GMT+08:00 jincheng sun : > > > Congratulations Shaoxuan. > > > > > > 2017-06-22 8:56 GMT+08:00 Zhangrucong

Re: [ANNOUNCE] New committer: Dawid Wysakowicz

Congrats! On Thu, Jun 22, 2017 at 5:51 AM Stavros Kontopoulos < st.kontopou...@gmail.com> wrote: > Congratulations Dawid! > > On Tue, Jun 20, 2017 at 12:06 PM, Vasudevan, Ramkrishna S < > ramkrishna.s.vasude...@intel.com> wrote: > > > Congratulations !! > > > > -Original Message- > >

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congrats, Shaoxuan Regards, Xiaogang 2017-06-22 9:08 GMT+08:00 jincheng sun : > Congratulations Shaoxuan. > > > 2017-06-22 8:56 GMT+08:00 Zhangrucong : > > > Congrats Shaoxuan! > > > > -邮件原件- > > 发件人: Fabian Hueske

[jira] [Created] (FLINK-6971) Add Alluxio Filesystem in Flink Ecosystem page

Bin Fan created FLINK-6971: -- Summary: Add Alluxio Filesystem in Flink Ecosystem page Key: FLINK-6971 URL: https://issues.apache.org/jira/browse/FLINK-6971 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congratulations Shaoxuan. 2017-06-22 8:56 GMT+08:00 Zhangrucong : > Congrats Shaoxuan! > > -邮件原件- > 发件人: Fabian Hueske [mailto:fhue...@gmail.com] > 发送时间: 2017年6月22日 4:19 > 收件人: dev@flink.apache.org > 主题: [ANNOUNCE] New Flink committer Shaoxuan Wang > > Hi

re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congrats Shaoxuan! -邮件原件- 发件人: Fabian Hueske [mailto:fhue...@gmail.com] 发送时间: 2017年6月22日 4:19 收件人: dev@flink.apache.org 主题: [ANNOUNCE] New Flink committer Shaoxuan Wang Hi everybody, On behalf of the PMC, I'm very happy to announce that Shaoxuan Wang has accepted the invitation of the

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congratulations Shaoxuan On Jun 21, 2017 1:19 PM, "Fabian Hueske" wrote: > Hi everybody, > > On behalf of the PMC, I'm very happy to announce that Shaoxuan Wang has > accepted the invitation of the PMC to become a Flink committer. > > Shaoxuan has contributed several major

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congratulations Shaoxuan! More hands are always welcomed! Kostas On Jun 21, 2017 22:45, "Greg Hogan" wrote: > Congrats and welcome, Shaoxuan! > > > > On Jun 21, 2017, at 4:19 PM, Fabian Hueske wrote: > > > > Hi everybody, > > > > On behalf of the PMC,

Re: [DISCUSS] Table API / SQL features for Flink 1.4.0

Hi Haohui, thanks for your input! Can you describe the semantics of the join you'd like to see in Flink 1.4? I can think of three types of joins that match your description: 1) `table` is an external table stored in an external database (redis, cassandra, MySQL, etc) and we join with the current

[jira] [Created] (FLINK-6969) Add support for deferred computation for group window aggregates

Fabian Hueske created FLINK-6969: Summary: Add support for deferred computation for group window aggregates Key: FLINK-6969 URL: https://issues.apache.org/jira/browse/FLINK-6969 Project: Flink

[jira] [Created] (FLINK-6968) Store streaming, updating tables with unique key in queryable state

Fabian Hueske created FLINK-6968: Summary: Store streaming, updating tables with unique key in queryable state Key: FLINK-6968 URL: https://issues.apache.org/jira/browse/FLINK-6968 Project: Flink

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congrats and welcome, Shaoxuan! > On Jun 21, 2017, at 4:19 PM, Fabian Hueske wrote: > > Hi everybody, > > On behalf of the PMC, I'm very happy to announce that Shaoxuan Wang has > accepted the invitation of the PMC to become a Flink committer. > > Shaoxuan has contributed

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congrats Shaoxuan! Z pozdrowieniami! / Cheers! Dawid Wysakowicz *Data/Software Engineer* Skype: dawid_wys | Twitter: @OneMoreCoder 2017-06-21 22:22 GMT+02:00 Ted Yu : > Congratulations, Shaoxuan > > On Wed, Jun 21, 2017 at 1:19 PM, Fabian Hueske

Re: [ANNOUNCE] New Flink committer Shaoxuan Wang

Congratulations, Shaoxuan On Wed, Jun 21, 2017 at 1:19 PM, Fabian Hueske wrote: > Hi everybody, > > On behalf of the PMC, I'm very happy to announce that Shaoxuan Wang has > accepted the invitation of the PMC to become a Flink committer. > > Shaoxuan has contributed several

[ANNOUNCE] New Flink committer Shaoxuan Wang

Hi everybody, On behalf of the PMC, I'm very happy to announce that Shaoxuan Wang has accepted the invitation of the PMC to become a Flink committer. Shaoxuan has contributed several major features to the Table API / SQL and is very engaged in discussions about the design of new features and the

Re: [DISCUSS] GitBox

+1 for trying out Gitbox! On Sun, Jun 18, 2017 at 6:50 PM, Greg Hogan wrote: > My understanding is that with GitBox project committers who have linked > Apache and GitHub accounts are given organization write permissions. Other > contributors will continue to have read

Re: [VOTE] Release Apache Flink 1.3.1 (RC2)

+1 Ran unit test suite which passed. On Wed, Jun 21, 2017 at 8:27 AM, Robert Metzger wrote: > +1 (binding) > > - Checked staging repository: ES5 connector is present > - quickstart-java points to 1.3.1 > - yarn session starts > - per-job YARN submission works / log files

Re: [VOTE] Release Apache Flink 1.3.1 (RC2)

+1 (binding) - Checked staging repository: ES5 connector is present - quickstart-java points to 1.3.1 - yarn session starts - per-job YARN submission works / log files look good. - Executed all tests listed here [1] without any issues / log files looked good afterwards - The source doesn't

Re: [VOTE] Release Apache Flink 1.3.1 (RC2)

+1 to release 1.3.1 as is. On 21.06.2017 17:06, Robert Metzger wrote: I see that this is an issue we should address, but on the other hand, there's a large list of issues we need to address with 1.3.1 already. If we keep delaying minor releases for every issue we find, we'll never release it :)

Re: [VOTE] Release Apache Flink 1.3.1 (RC2)

I see that this is an issue we should address, but on the other hand, there's a large list of issues we need to address with 1.3.1 already. If we keep delaying minor releases for every issue we find, we'll never release it :) On Wed, Jun 21, 2017 at 3:51 PM, Stefan Richter

[jira] [Created] (FLINK-6967) Fully separate batch and storm examples

Chesnay Schepler created FLINK-6967: --- Summary: Fully separate batch and storm examples Key: FLINK-6967 URL: https://issues.apache.org/jira/browse/FLINK-6967 Project: Flink Issue Type:

Re: [DISCUSS] Changing Flink's shading model

Okay, I'll request a repo for the shading. On Wed, Jun 21, 2017 at 1:38 PM, Chesnay Schepler wrote: > I like your suggestion Robert. A lot actually. > > Having the actual dependency version (i.e 18 for guava) in the version > should improve clarity a lot. > > Originally i

Re: [DISCUSS] Table API / SQL features for Flink 1.4.0

Hi, We are interested in building the simplest case of stream-table joins -- essentially calling stream.map(x => (x, table.get(x)). It solves the use cases of augmenting the streams with the information of the database. The operation itself can be batched for better performance. We are happy to

Looking for Contributors: Apache Flink meets Apache Mesos and DC/OS

Hi, we are actively looking for contributors (and anyone interested) for the Flink DC/OS package, as well as the Mesos Flink framework. We will have a first meeting to explain the current package and outline/develop a potential roadmap in the next virtual DC/OS office hours:

[jira] [Created] (FLINK-6965) Avro is missing snappy dependency

Chesnay Schepler created FLINK-6965: --- Summary: Avro is missing snappy dependency Key: FLINK-6965 URL: https://issues.apache.org/jira/browse/FLINK-6965 Project: Flink Issue Type: Bug

Re: [VOTE] Release Apache Flink 1.3.1 (RC2)

Hi, I suggest to include https://issues.apache.org/jira/browse/FLINK-6964 to the release. Best, Stefan > Am 21.06.2017 um 09:46 schrieb Robert Metzger : > > Dear Flink community, > > Please vote on releasing the

Re: [DISCUSS] Changing Flink's shading model

I like your suggestion Robert. A lot actually. Having the actual dependency version (i.e 18 for guava) in the version should improve clarity a lot. Originally i intended to release 1 artifact per Flink version, with the normal versioning scheme that we use. But given that the shaded

[jira] [Created] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

Stefan Richter created FLINK-6964: - Summary: Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore Key: FLINK-6964 URL: https://issues.apache.org/jira/browse/FLINK-6964

[jira] [Created] (FLINK-6963) User Defined Operator

Shaoxuan Wang created FLINK-6963: Summary: User Defined Operator Key: FLINK-6963 URL: https://issues.apache.org/jira/browse/FLINK-6963 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-6962) SQL DDL for input and output tables

Shaoxuan Wang created FLINK-6962: Summary: SQL DDL for input and output tables Key: FLINK-6962 URL: https://issues.apache.org/jira/browse/FLINK-6962 Project: Flink Issue Type: New Feature

Re: [DISCUSS] Changing Flink's shading model

Its not completely clear to me how we want to version the shaded dependencies, and where we are putting them. One concern are the official apache release rules. If we want to release something to maven central, we need to do a proper vote over a source archive. I would propose to create a new

[jira] [Created] (FLINK-6961) Enable configurable early-firing rate

Shaoxuan Wang created FLINK-6961: Summary: Enable configurable early-firing rate Key: FLINK-6961 URL: https://issues.apache.org/jira/browse/FLINK-6961 Project: Flink Issue Type: New Feature

[VOTE] Release Apache Flink 1.3.1 (RC2)

Dear Flink community, Please vote on releasing the following candidate as Apache Flink version 1.3.1. The commit to be voted on: *http://git-wip-us.apache.org/repos/asf/flink/commit/1ca6e5b6 * Branch: release-1.3.1-rc2 The release

[jira] [Created] (FLINK-6960) Add E(2.7182818284590452354),PI(3.14159265358979323846) supported in SQL

sunjincheng created FLINK-6960: -- Summary: Add E(2.7182818284590452354),PI(3.14159265358979323846) supported in SQL Key: FLINK-6960 URL: https://issues.apache.org/jira/browse/FLINK-6960 Project: Flink

[jira] [Created] (FLINK-6959) Add documentation for SQL OVER windows

sunjincheng created FLINK-6959: -- Summary: Add documentation for SQL OVER windows Key: FLINK-6959 URL: https://issues.apache.org/jira/browse/FLINK-6959 Project: Flink Issue Type: Improvement