[jira] [Created] (FLINK-16123) Add routable Kafka connector

2020-02-17 Thread Igal Shilman (Jira)
Igal Shilman created FLINK-16123: Summary: Add routable Kafka connector Key: FLINK-16123 URL: https://issues.apache.org/jira/browse/FLINK-16123 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16122) build system: transfer.sh uploads are unstable (February 2020)

2020-02-17 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-16122: -- Summary: build system: transfer.sh uploads are unstable (February 2020) Key: FLINK-16122 URL: https://issues.apache.org/jira/browse/FLINK-16122 Project: Flink

Re: [DISCUSS] FLIP-92: JDBC catalog and Postgres catalog

2020-02-17 Thread Bowen Li
Hi all, If there's no more comments, I would like to kick off a vote for this FLIP [1]. FYI, the flip number is changed to 93 since there was a race condition of taking 92. [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-93%3A+JDBC+catalog+and+Postgres+catalog On Wed, Jan 22, 2020

Re: Hotfixes on the master

2020-02-17 Thread Robert Metzger
Hi all, I would like to revive this very old thread on the topic of "unreviewed hotfixes on master" again. Out of the 35 commits listed on the latest commits page on GitHub, 18 have the tag "hotfix", on the next page it is 9, then 16, 17, ... In the last 140 commits, 42% were hotfixes. For the

Re: [DISCUSS] Remove transfer.sh from CI setup

2020-02-17 Thread Robert Metzger
Tracking this here: https://issues.apache.org/jira/browse/FLINK-16122 On Sat, Feb 15, 2020 at 8:12 PM Robert Metzger wrote: > I agree that we need to fix this. > > We could either misuse the "build artifact" feature of azure pipelines to > publish the logs, or we set up something simple for

Re: [DISCUSS] Improve history server with log support

2020-02-17 Thread Rong Rong
Hi All, Thank you all for the prompt feedbacks. Based on the discussion I think this seems to be a very useful feature. I would start an initial draft of a design doc (or should it be a FLIP?) and share with the community. Hi Yang, Thanks for the interest and thanks for sharing the ideas. In

[DISCUSS] AssignerWithPeriodicWatermarks with max delay

2020-02-17 Thread Eduardo Winpenny Tejedor
Hi all, I've been using Apache Flink for the last few months but I'm new to the dev community. I'd like to contribute code (and possibly more) to the community and I've been advised a good starting point would be suggesting improvements for those areas that I found lacking. I'll create a separate

[jira] [Created] (FLINK-16133) Translate "Azure Blob Storage" page of "File Systems" into Chinese

2020-02-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-16133: --- Summary: Translate "Azure Blob Storage" page of "File Systems" into Chinese Key: FLINK-16133 URL: https://issues.apache.org/jira/browse/FLINK-16133 Project: Flink

[jira] [Created] (FLINK-16124) Add a AWS Kinesis Stateful Functions Ingress

2020-02-17 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16124: --- Summary: Add a AWS Kinesis Stateful Functions Ingress Key: FLINK-16124 URL: https://issues.apache.org/jira/browse/FLINK-16124 Project: Flink

Re: Would you please give me the permission as a contributor?

2020-02-17 Thread Benchao Li
Hi bin, Welcome to the community! You no longer need contributor permissions. You can simply create a JIRA ticket and ask to be assigned to work on it. Please also take a look at the Flink's contribution guidelines [1] for more information. [1]

[jira] [Created] (FLINK-16125) Make zookeeper.connect optional for Kafka connectors

2020-02-17 Thread Jiangjie Qin (Jira)
Jiangjie Qin created FLINK-16125: Summary: Make zookeeper.connect optional for Kafka connectors Key: FLINK-16125 URL: https://issues.apache.org/jira/browse/FLINK-16125 Project: Flink Issue

Re: [DISCUSS][TABLE] Issue with package structure in the Table API

2020-02-17 Thread Jingsong Li
Thanks for bringing this discussion. +1 to peforming this big change as early as possible. You solved my question, why we need "_root_". Yes, I don't like this import too. And it is very strange that expressionDsl is in api, but can only work in api.scala. (Because scala extends

[jira] [Created] (FLINK-16126) Translate all connector related pages into Chinese

2020-02-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-16126: --- Summary: Translate all connector related pages into Chinese Key: FLINK-16126 URL: https://issues.apache.org/jira/browse/FLINK-16126 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16128) Translate "Google Cloud PubSub" page into Chinese

2020-02-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-16128: --- Summary: Translate "Google Cloud PubSub" page into Chinese Key: FLINK-16128 URL: https://issues.apache.org/jira/browse/FLINK-16128 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Improve history server with log support

2020-02-17 Thread SHI Xiaogang
Hi all, Thanks a lot for your interest. We are very interesting to contribute the trace system to the community. We will draft a design document and share it soon. The trace system actually is an complement to existing metric and logging systems, and definitely can not replace the logging

[jira] [Created] (FLINK-16131) Translate "Amazon S3" page of "File Systems" into Chinese

2020-02-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-16131: --- Summary: Translate "Amazon S3" page of "File Systems" into Chinese Key: FLINK-16131 URL: https://issues.apache.org/jira/browse/FLINK-16131 Project: Flink Issue Type:

[jira] [Created] (FLINK-16132) Translate "Aliyun OSS" page of "File Systems" into Chinese

2020-02-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-16132: --- Summary: Translate "Aliyun OSS" page of "File Systems" into Chinese Key: FLINK-16132 URL: https://issues.apache.org/jira/browse/FLINK-16132 Project: Flink Issue

[jira] [Created] (FLINK-16130) Translate "Common Configurations" page of "File Systems" into Chinese

2020-02-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-16130: --- Summary: Translate "Common Configurations" page of "File Systems" into Chinese Key: FLINK-16130 URL: https://issues.apache.org/jira/browse/FLINK-16130 Project: Flink

[jira] [Created] (FLINK-16129) Translate "Overview" page of "File Systems" into Chinese

2020-02-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-16129: --- Summary: Translate "Overview" page of "File Systems" into Chinese Key: FLINK-16129 URL: https://issues.apache.org/jira/browse/FLINK-16129 Project: Flink Issue Type:

Would you please give me the permission as a contributor?

2020-02-17 Thread bin dong
Hi men, I wanna contribute to Apache Flink. Would you please give me the permission as a contributor? My JIRA ID is dongbin

[jira] [Created] (FLINK-16127) Translate "Fault Tolerance Guarantees" page of connectors into Chinese

2020-02-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-16127: --- Summary: Translate "Fault Tolerance Guarantees" page of connectors into Chinese Key: FLINK-16127 URL: https://issues.apache.org/jira/browse/FLINK-16127 Project: Flink

[jira] [Created] (FLINK-16116) Remove shading from oss filesystems build

2020-02-17 Thread Yang Wang (Jira)
Yang Wang created FLINK-16116: - Summary: Remove shading from oss filesystems build Key: FLINK-16116 URL: https://issues.apache.org/jira/browse/FLINK-16116 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-16117) Avoid register source in TableTestBase#addTableSource

2020-02-17 Thread Zhenghua Gao (Jira)
Zhenghua Gao created FLINK-16117: Summary: Avoid register source in TableTestBase#addTableSource Key: FLINK-16117 URL: https://issues.apache.org/jira/browse/FLINK-16117 Project: Flink Issue

[jira] [Created] (FLINK-16118) testDynamicTableFunction fails

2020-02-17 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-16118: - Summary: testDynamicTableFunction fails Key: FLINK-16118 URL: https://issues.apache.org/jira/browse/FLINK-16118 Project: Flink Issue Type: Bug

Re: [DISCUSS] Migrate build infrastructure from Travis CI to Azure Pipelines

2020-02-17 Thread Robert Metzger
@Leonard: On Azure, I'm not splitting the execution of the end to end tests anymore. We won't have the overhead of compiling the same profile multiple times anymore. @all: We have recently merged a first version of the Azure configuration files to Flink [1]. This will allow us to build pull

Re: [DISCUSS] Remove registration of TableSource/TableSink in Table Env and ConnectTableDescriptor

2020-02-17 Thread Timo Walther
Hi Kurt, no there is no JIRA ticket yet. But in any case, I think it is better to have good testing infrastructure that abstracts source generation, sink generation, testing data etc. If we will introduce tableEnv.values() it will also not solve everything because time-based operations might

[jira] [Created] (FLINK-16115) Aliyun oss filesystem could not work with plugin mechanism

2020-02-17 Thread Yang Wang (Jira)
Yang Wang created FLINK-16115: - Summary: Aliyun oss filesystem could not work with plugin mechanism Key: FLINK-16115 URL: https://issues.apache.org/jira/browse/FLINK-16115 Project: Flink Issue

Re: [ANNOUNCE] New Documentation Style Guide

2020-02-17 Thread Yu Li
I think the guide itself is a great example of the new style! Thanks for driving this, Aljoscha! Best Regards, Yu On Mon, 17 Feb 2020 at 16:44, Becket Qin wrote: > The guideline is very practical! I like it! Thanks for putting it together, > Aljoscha. > > Jiangjie (Becket) Qin > > On Mon, Feb

Re: [ANNOUNCE] New Documentation Style Guide

2020-02-17 Thread jincheng sun
Thanks for this great job Aljoscha! Best, Jincheng Yu Li 于2020年2月17日周一 下午6:42写道: > I think the guide itself is a great example of the new style! Thanks for > driving this, Aljoscha! > > Best Regards, > Yu > > > On Mon, 17 Feb 2020 at 16:44, Becket Qin wrote: > > > The guideline is very

Re: [ANNOUNCE] New Documentation Style Guide

2020-02-17 Thread Becket Qin
The guideline is very practical! I like it! Thanks for putting it together, Aljoscha. Jiangjie (Becket) Qin On Mon, Feb 17, 2020 at 10:04 AM Xintong Song wrote: > Thanks for the summary! > > I've read through the guidelines and found it very helpful. Many of the > questions I had while working

[jira] [Created] (FLINK-16114) Support Scalar Vectorized Python UDF in PyFlink

2020-02-17 Thread Dian Fu (Jira)
Dian Fu created FLINK-16114: --- Summary: Support Scalar Vectorized Python UDF in PyFlink Key: FLINK-16114 URL: https://issues.apache.org/jira/browse/FLINK-16114 Project: Flink Issue Type: New

[jira] [Created] (FLINK-16113) ExpressionReducer shouldn't escape the reduced string value

2020-02-17 Thread Jark Wu (Jira)
Jark Wu created FLINK-16113: --- Summary: ExpressionReducer shouldn't escape the reduced string value Key: FLINK-16113 URL: https://issues.apache.org/jira/browse/FLINK-16113 Project: Flink Issue

[RESULT][VOTE] FLIP-97: Support scalar vectorized Python UDF in PyFlink

2020-02-17 Thread Dian Fu
Hi all, Thanks you all for the discussion and votes. So far, we have - 3 binding +1 votes (Jincheng, Hequn, Dian) - 1 non-binding +1 votes (Jingsong) - No -1 votes The voting time has passed and there are enough +1 votes. Therefore, I'm happy to announce that FLIP-97[1] has been accepted.

Re: [ANNOUNCE] New Documentation Style Guide

2020-02-17 Thread Hequn Cheng
Thanks Marta and Aljoscha for the detailed document! This is very helpful. Best, Hequn On Mon, Feb 17, 2020 at 9:07 PM Aljoscha Krettek wrote: > Just to be clear: I didn't write this style guide. Marta (in cc) wrote > this, I just finally merged it. > > Best, > Aljoscha > > On 17.02.20 11:45,

[RESULT][VOTE] Release flink-shaded 10.0, release candidate #3

2020-02-17 Thread Chesnay Schepler
I'm happy to announce that we have unanimously approved this release. There are XXX approving votes, XXX of which are binding: - Yu (non-binding) - Ufuk (binding) - Zhu (non-binding) - Hequn (non-binding) - Dian (non-binding) - Robert (binding) - Zhijiang (non-binding) - Jincheng (binding)

[jira] [Created] (FLINK-16120) Update the hive section of the connectors doc

2020-02-17 Thread Rui Li (Jira)
Rui Li created FLINK-16120: -- Summary: Update the hive section of the connectors doc Key: FLINK-16120 URL: https://issues.apache.org/jira/browse/FLINK-16120 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-16121) Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-17 Thread Dian Fu (Jira)
Dian Fu created FLINK-16121: --- Summary: Introduce ArrowReader and ArrowWriter for Arrow format data read and write Key: FLINK-16121 URL: https://issues.apache.org/jira/browse/FLINK-16121 Project: Flink

[jira] [Created] (FLINK-16119) Port base RelNode classes from Scala to Java

2020-02-17 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16119: --- Summary: Port base RelNode classes from Scala to Java Key: FLINK-16119 URL: https://issues.apache.org/jira/browse/FLINK-16119 Project: Flink Issue Type:

Re: [ANNOUNCE] New Documentation Style Guide

2020-02-17 Thread Aljoscha Krettek
Just to be clear: I didn't write this style guide. Marta (in cc) wrote this, I just finally merged it. Best, Aljoscha On 17.02.20 11:45, jincheng sun wrote: Thanks for this great job Aljoscha! Best, Jincheng Yu Li 于2020年2月17日周一 下午6:42写道: I think the guide itself is a great example of

Re: [Discuss] Update the pull request description template.

2020-02-17 Thread Chesnay Schepler
I think it should just be removed since 99% of pull requests ignore it anyway. On 17/02/2020 13:31, Xintong Song wrote: Hi all, It seems our PR description template is a bit outdated, and I would like to propose updating it. I was working on a Kubernetes related PR, and realized that our PR

Re: [Discuss] Update the pull request description template.

2020-02-17 Thread Congxian Qiu
JFYI, there is an issue[1] which I think is related to this thread [1] https://issues.apache.org/jira/browse/FLINK-15977 Best, Congxian Chesnay Schepler 于2020年2月17日周一 下午9:08写道: > I think it should just be removed since 99% of pull requests ignore it > anyway. > > On 17/02/2020 13:31, Xintong

[Discuss] Update the pull request description template.

2020-02-17 Thread Xintong Song
Hi all, It seems our PR description template is a bit outdated, and I would like to propose updating it. I was working on a Kubernetes related PR, and realized that our PR description does not mention the new Kubernetes integration questioning about deployment related changes. Currently is is as