Re: [DISCUSS] Flink client api enhancement for downstream project

Hi all, After a closer look on our client apis, I can see there are two major issues to consistency and integration, namely different deployment of job cluster which couples job graph creation and cluster deployment, and submission via CliFrontend confusing control flow of job graph compilation an

Re: Something wrong with travis?

Unfortunately, I met this problem again just now https://api.travis-ci.org/v3/job/549534496/log.txt (the build overview https://travis-ci.org/apache/flink/builds/549534489). For those non-committers, including me, we have to close-reopen the PR or push another commit to re-trigger the PR check🙁

[jira] [Created] (FLINK-12956) Add a upsert table sink for JDBC

Jingsong Lee created FLINK-12956: Summary: Add a upsert table sink for JDBC Key: FLINK-12956 URL: https://issues.apache.org/jira/browse/FLINK-12956 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-12955) Add HBase LookupableTableSource

Chance Li created FLINK-12955: - Summary: Add HBase LookupableTableSource Key: FLINK-12955 URL: https://issues.apache.org/jira/browse/FLINK-12955 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-12954) Supports watermark and create view for sql parser

Danny Chan created FLINK-12954: -- Summary: Supports watermark and create view for sql parser Key: FLINK-12954 URL: https://issues.apache.org/jira/browse/FLINK-12954 Project: Flink Issue Type: Sub

Re: [DISCUSS] Start a user...@flink.apache.org mailing list for the Chinese-speaking community?

Hi, I'd like to share you the result of the survey. Thanks for the help from @Gordon, @Jark and the Flink China operation team when conducting the survey. A total of 81 people participated in the survey. 46 of them choose not to use the mailing list. Among these people, the reasons are(Note that

[jira] [Created] (FLINK-12953) View logs from Job view in Web Dashboard

Chad Dombrova created FLINK-12953: - Summary: View logs from Job view in Web Dashboard Key: FLINK-12953 URL: https://issues.apache.org/jira/browse/FLINK-12953 Project: Flink Issue Type: Improv

[ANNOUNCE] Weekly Community Update 2019/25

Dear community, this week's update contains a few pointers to upcoming changes in the development process, two recent proposals around metrics as well as smaller discussions on the dev mailing list. Still processing the backlog of topics & discussions by including a few of them each week. As alwa

Re: [DISCUSS] Adopting a Code Style and Quality Guide

I love this kind of unification being pushed forward, the benefit it has on code reviews is enormous. Just my two cents, did you guys think about adopting an automatic code formatter for java, the same way as Apache Beam did? It is super easy to use for contributors as they don't need to keep any

get contributor permission

Hi, I want to contribute to Apache Flink. Would you please give me the contributor permission? My JIRA ID is jinxl. jinxiaolong_al...@163.com

Re: [DISCUSS] Connectors and NULL handling

Error handling policy for streaming jobs goes beyond potential corrupted messages in the source. Users may have subtle bugs while processing some messages which may cause the streaming jobs to fail. Even though this can be considered as a bug in user's code, users may prefer skip such messages (or

Re: Specifying parallelism on join operation

You can use with(JoinFunction) to workaround it. See JavaDoc for Flink 1.8: @PublicEvolving