Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Many thanks for your support. Thank you! Best, Hequn On Sat, Apr 18, 2020 at 1:27 AM Jacky Bai wrote: > Congratulations！Hequn Chen.I hope to make so many contributions to Flink > like you. > > Best > Bai Xu > > Congxian Qiu 于2020年4月17日周五 下午10:47写道： > > > Congratulations, Hequn! > > > > Best,

[jira] [Created] (FLINK-17229) Add a flink-sql-client-sdk module

molsion created FLINK-17229: --- Summary: Add a flink-sql-client-sdk module Key: FLINK-17229 URL: https://issues.apache.org/jira/browse/FLINK-17229 Project: Flink Issue Type: Improvement

[VOTE] Release 1.9.3, release candidate #1

Hi everyone, Please review and vote on the release candidate #1 for the version 1.9.3, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) The complete staging area is available for your review, which includes: * JIRA release notes [1],

Re: [DISCUSS] Integration of training materials into Apache Flink

I'm not able to create the repository. INFRA requests that new repos are created using https://selfserve.apache.org/ and it requires a PMC member. It looks like it should take someone 30 seconds. Seth On Fri, Apr 17, 2020 at 9:07 AM David Anderson wrote: > @Robert, do you think we could create

Re: [DISCUSS] Switch to Azure Pipelines as the primary CI tool / switch off Travis

Thanks a lot for bringing up this topic again. The reason why I was hesitant to decommission Travis was that we were still facing some issues with the Azure infrastructure that I want to resolve, so that we have a strong test coverage. In the last few weeks, we had the following issues: -

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations！Hequn Chen.I hope to make so many contributions to Flink like you. Best Bai Xu Congxian Qiu 于2020年4月17日周五 下午10:47写道： > Congratulations, Hequn! > > Best, > Congxian > > > Yu Li 于2020年4月17日周五 下午9:36写道： > > > Congratulations, Hequn! > > > > Best Regards, > > Yu > > > > > > On

[jira] [Created] (FLINK-17228) Streaming sql with nested GROUP BY got wrong results

Xingxing Di created FLINK-17228: --- Summary: Streaming sql with nested GROUP BY got wrong results Key: FLINK-17228 URL: https://issues.apache.org/jira/browse/FLINK-17228 Project: Flink Issue

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

Thanks Jark! I certainly need to read up on FLIP-105 (and I'll try to adjust my terminology to changelog table from now on ;-) ) If FLIP-105 addresses the issue of converting an append-only table into a changelog table that upserts on primary key (basically what the VIEW definition in my first

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

Hi Fabian, I think converting an append-only table into temporal table contains two things: (1) converting append-only table into changelog table (or retraction table as you said) (2) define the converted changelog table (maybe is a view now) as temporal (or history tracked). The first thing is

[jira] [Created] (FLINK-17227) Remove Datadog relocations

Chesnay Schepler created FLINK-17227: Summary: Remove Datadog relocations Key: FLINK-17227 URL: https://issues.apache.org/jira/browse/FLINK-17227 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17226) Remove Prometheus relocations

Chesnay Schepler created FLINK-17226: Summary: Remove Prometheus relocations Key: FLINK-17226 URL: https://issues.apache.org/jira/browse/FLINK-17226 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

Hi, I agree with most of what Timo said. The TEMPORAL keyword (which unfortunately might be easily confused with TEMPORARY...) looks very intuitive and I think using the only time attribute for versioning would be a good choice. However, TEMPORAL TABLE on retraction tables do not solve the full

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

I really like the TEMPORAL keyword, I find it very intuitive. The down side of this approach would be that an additional preprocessing > step would not be possible anymore because there is no preceding view. > Yes and no. My understanding is we are not talking about making any changes to how

[jira] [Created] (FLINK-17225) Support native k8s for scala shell

Yang Wang created FLINK-17225: - Summary: Support native k8s for scala shell Key: FLINK-17225 URL: https://issues.apache.org/jira/browse/FLINK-17225 Project: Flink Issue Type: New Feature

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations, Hequn! Best, Congxian Yu Li 于2020年4月17日周五 下午9:36写道： > Congratulations, Hequn! > > Best Regards, > Yu > > > On Fri, 17 Apr 2020 at 21:22, Kurt Young wrote: > > > Congratulations Hequn! > > > > Best, > > Kurt > > > > > > On Fri, Apr 17, 2020 at 8:57 PM Till Rohrmann > >

Re: [DISCUSS] Releasing "fat" and "slim" Flink distributions

@Aljoscha I think that is an interesting line of thinking. the swift-fs may be rarely enough used to move it to an optional download. I would still drop two more thoughts: (1) Now that we have plugins support, is there a reason to have a metrics reporter or file system in /opt instead of

[jira] [Created] (FLINK-17224) Precision of TIME type does not work correctly

Dawid Wysakowicz created FLINK-17224: Summary: Precision of TIME type does not work correctly Key: FLINK-17224 URL: https://issues.apache.org/jira/browse/FLINK-17224 Project: Flink Issue

Re: [DISCUSS] Integration of training materials into Apache Flink

@Robert, do you think we could create a new flink-training component in Jira for tracking tickets related to the flink-training content? David On Thu, Apr 16, 2020 at 10:54 AM David Anderson wrote: > > I am happy to get the repo created for you. > > Thank you, @seth. I think we are also going

[jira] [Created] (FLINK-17223) System.IO.IOException: No space left on device in misc profile on free Azure builders

Robert Metzger created FLINK-17223: -- Summary: System.IO.IOException: No space left on device in misc profile on free Azure builders Key: FLINK-17223 URL: https://issues.apache.org/jira/browse/FLINK-17223

[jira] [Created] (FLINK-17222) Improve FieldsDataType

Dawid Wysakowicz created FLINK-17222: Summary: Improve FieldsDataType Key: FLINK-17222 URL: https://issues.apache.org/jira/browse/FLINK-17222 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations, Hequn! Best Regards, Yu On Fri, 17 Apr 2020 at 21:22, Kurt Young wrote: > Congratulations Hequn! > > Best, > Kurt > > > On Fri, Apr 17, 2020 at 8:57 PM Till Rohrmann > wrote: > > > Congratulations Hequn! > > > > Cheers, > > Till > > > > On Fri, Apr 17, 2020 at 2:49 PM Shuo

[jira] [Created] (FLINK-17221) Flink on YARN fails with NoClassDefFoundError: com/sun/jersey/core/util/FeaturesAndProperties

Sivaprasanna Sethuraman created FLINK-17221: --- Summary: Flink on YARN fails with NoClassDefFoundError: com/sun/jersey/core/util/FeaturesAndProperties Key: FLINK-17221 URL:

Re: Are there any link between the flink project.version and flink.shaded.version

This may have been to short of an answer. If you are using flink-shaded-hadoop, use the latest version. In all other cases (e.g., flink-shaded-jackson), then depend on what the Flink version you work against depends on. For example, 1.10 works against flink-shaded 9.0 . However, you

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations Hequn! Best, Kurt On Fri, Apr 17, 2020 at 8:57 PM Till Rohrmann wrote: > Congratulations Hequn! > > Cheers, > Till > > On Fri, Apr 17, 2020 at 2:49 PM Shuo Cheng wrote: > > > Congratulations, Hequn > > > > Best, > > Shuo > > > > On 4/17/20, hufeih...@mails.ucas.ac.cn >

Re: Are there any link between the flink project.version and flink.shaded.version

There is no link; you generally want to use the latest flink-shaded version. On 17/04/2020 14:59, Sivaprasanna wrote: I see quite a few flink.shaded.version in maven repo like 9.0, 10.0, 11.0 being the latest. I just wanted to understand how to decide which flink.shaded.version to use in the

Are there any link between the flink project.version and flink.shaded.version

I see quite a few flink.shaded.version in maven repo like 9.0, 10.0, 11.0 being the latest. I just wanted to understand how to decide which flink.shaded.version to use in the user application? Thanks :)

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations Hequn! Cheers, Till On Fri, Apr 17, 2020 at 2:49 PM Shuo Cheng wrote: > Congratulations, Hequn > > Best, > Shuo > > On 4/17/20, hufeih...@mails.ucas.ac.cn wrote: > > Congratulations , Hequn > > > > Best wish > > > > > > hufeih...@mails.ucas.ac.cn > > Congratulations, Hequn! >

[jira] [Created] (FLINK-17220) It reports "No space left on device" on azure pipeline

Dian Fu created FLINK-17220: --- Summary: It reports "No space left on device" on azure pipeline Key: FLINK-17220 URL: https://issues.apache.org/jira/browse/FLINK-17220 Project: Flink Issue Type: Bug

Re: [PROPOSAL] Google Season of Docs 2020.

Thanks for driving this effort Marta. I'd be up for mentoring improvements for the deployment section as described in FLIP-42. Cheers, Till On Fri, Apr 17, 2020 at 11:20 AM Aljoscha Krettek wrote: > Hi, > > first, excellent that you're driving this, Marta! > > By now I have made quite some

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations, Hequn Best, Shuo On 4/17/20, hufeih...@mails.ucas.ac.cn wrote: > Congratulations , Hequn > > Best wish > > > hufeih...@mails.ucas.ac.cn > Congratulations, Hequn! > > Paul Lam 于2020年4月17日周五 下午3:02写道： > >> Congrats Hequn! Thanks a lot for your contribution to the community! >>

Re: [DISCUSS] [FLINK-16824] Creating Temporal Table Function via DDL

Hi all, First of all, I appologize for the text wall that's following... ;-) A temporal table join joins an append-only table and a temporal table. The question about how to represent a temporal table join boils down to two questions: 1) How to represent a temporal table 2) How to specify the

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations, Hequn Best wish hufeih...@mails.ucas.ac.cn 于2020年4月17日周五 下午8:29写道： > Congratulations , Hequn > > Best wish > > > hufeih...@mails.ucas.ac.cn > Congratulations, Hequn! > > Paul Lam 于2020年4月17日周五 下午3:02写道： > > > Congrats Hequn! Thanks a lot for your contribution to the

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congrats Hequn! Am Fr., 17. Apr. 2020 um 14:29 Uhr schrieb hufeih...@mails.ucas.ac.cn < hufeih...@mails.ucas.ac.cn>: > Congratulations , Hequn > > Best wish > > > hufeih...@mails.ucas.ac.cn > Congratulations, Hequn! > > Paul Lam 于2020年4月17日周五 下午3:02写道： > > > Congrats Hequn! Thanks a lot for

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations , Hequn Best wish hufeih...@mails.ucas.ac.cn Congratulations, Hequn! Paul Lam 于2020年4月17日周五 下午3:02写道： > Congrats Hequn! Thanks a lot for your contribution to the community! > > Best, > Paul Lam > > Dian Fu 于2020年4月17日周五 下午2:58写道： > > > Congratulations, Hequn! > > > > > 在

[jira] [Created] (FLINK-17219) start-cluster.bat doesn't run task manager due to misconfiguration that is released default configuration

Bulent Coskun created FLINK-17219: - Summary: start-cluster.bat doesn't run task manager due to misconfiguration that is released default configuration Key: FLINK-17219 URL:

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations! Best, Xingbo tison 于2020年4月17日周五 下午6:43写道： > Congrats! > > Best, > tison. > > > Yun Tang 于2020年4月17日周五 下午6:40写道： > > > Congratulations , Hequn > > > > Best > > Yun Tang > > > > From: Guowei Ma > > Sent: Friday, April 17, 2020 18:27 > > To:

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congrats! Best, tison. Yun Tang 于2020年4月17日周五 下午6:40写道： > Congratulations , Hequn > > Best > Yun Tang > > From: Guowei Ma > Sent: Friday, April 17, 2020 18:27 > To: dev > Subject: Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen > > Congratulations! >

[jira] [Created] (FLINK-17218) Add recovery to integration tests of unaligned checkpoints

Arvid Heise created FLINK-17218: --- Summary: Add recovery to integration tests of unaligned checkpoints Key: FLINK-17218 URL: https://issues.apache.org/jira/browse/FLINK-17218 Project: Flink

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations , Hequn Best Yun Tang From: Guowei Ma Sent: Friday, April 17, 2020 18:27 To: dev Subject: Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen Congratulations! Best, Guowei Xintong Song 于2020年4月17日周五 下午5:21写道： > Congratulations, Hequn~!

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations! Best, Guowei Xintong Song 于2020年4月17日周五 下午5:21写道： > Congratulations, Hequn~! > > Thank you~ > > Xintong Song > > > > On Fri, Apr 17, 2020 at 4:50 PM godfrey he wrote: > > > Congratulations, Hequn! > > > > Best, > > Godfrey > > > > Leonard Xu 于2020年4月17日周五 下午4:30写道： > > > >

Re: [DISCUSS] Releasing "fat" and "slim" Flink distributions

I think having such tools and/or tailor-made distributions can be nice but I also think the discussion is missing the main point: The initial observation/motivation is that apparently a lot of users (Kurt and I talked about this) on the chinese DingTalk support groups, and other support

Re: [DISCUSS] Releasing "fat" and "slim" Flink distributions

A similar issue exists for the docker files. I also heard the fame feedback from various users, for example why we don't simply include all FS connectors in the images by default. I actually like the idea of having a slim and a fat/convenience docker file. - If you build a clean production

[jira] [Created] (FLINK-17217) Download links for central.maven.org in doc don't work

Aljoscha Krettek created FLINK-17217: Summary: Download links for central.maven.org in doc don't work Key: FLINK-17217 URL: https://issues.apache.org/jira/browse/FLINK-17217 Project: Flink

[jira] [Created] (FLINK-17216) Allow user to provide credential provider to Elasticsearch rest client.

Yangze Guo created FLINK-17216: -- Summary: Allow user to provide credential provider to Elasticsearch rest client. Key: FLINK-17216 URL: https://issues.apache.org/jira/browse/FLINK-17216 Project: Flink

[jira] [Created] (FLINK-17215) Clean the build document for Pyflink

Hequn Cheng created FLINK-17215: --- Summary: Clean the build document for Pyflink Key: FLINK-17215 URL: https://issues.apache.org/jira/browse/FLINK-17215 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17214) Docker entry po

Chesnay Schepler created FLINK-17214: Summary: Docker entry po Key: FLINK-17214 URL: https://issues.apache.org/jira/browse/FLINK-17214 Project: Flink Issue Type: Bug

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations, Hequn~! Thank you~ Xintong Song On Fri, Apr 17, 2020 at 4:50 PM godfrey he wrote: > Congratulations, Hequn! > > Best, > Godfrey > > Leonard Xu 于2020年4月17日周五 下午4:30写道： > > > Congratulations! > > > > Best, > > Leonard Xu > > > 在 2020年4月17日，15:46，Benchao Li 写道： > > > > > >

Re: [PROPOSAL] Google Season of Docs 2020.

Hi, first, excellent that you're driving this, Marta! By now I have made quite some progress on the FLIP-42 restructuring so that is not a good effort for someone to join now. Plus there is also [1], which is about incorporating the existing Flink Training material into the concepts section

[jira] [Created] (FLINK-17213) Surefire configuration should override locale

Etienne Chauchot created FLINK-17213: Summary: Surefire configuration should override locale Key: FLINK-17213 URL: https://issues.apache.org/jira/browse/FLINK-17213 Project: Flink Issue

[jira] [Created] (FLINK-17212) Disable the cython tests

Huang Xingbo created FLINK-17212: Summary: Disable the cython tests Key: FLINK-17212 URL: https://issues.apache.org/jira/browse/FLINK-17212 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations, Hequn! Best, Godfrey Leonard Xu 于2020年4月17日周五 下午4:30写道： > Congratulations! > > Best, > Leonard Xu > > 在 2020年4月17日，15:46，Benchao Li 写道： > > > > Congratulations Hequn! > > > > Stephan Ewen 于2020年4月17日周五 下午3:42写道： > > > >> Congrats! > >> > >> On Fri, Apr 17, 2020 at 9:40 AM

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations! Best, Leonard Xu > 在 2020年4月17日，15:46，Benchao Li 写道： > > Congratulations Hequn! > > Stephan Ewen 于2020年4月17日周五 下午3:42写道： > >> Congrats! >> >> On Fri, Apr 17, 2020 at 9:40 AM Jark Wu wrote: >> >>> Congratulations Hequn! >>> >>> Best, >>> Jark >>> >>> On Fri, 17 Apr 2020

[jira] [Created] (FLINK-17211) Some tests in flink-sql-parser module were disabled

Dawid Wysakowicz created FLINK-17211: Summary: Some tests in flink-sql-parser module were disabled Key: FLINK-17211 URL: https://issues.apache.org/jira/browse/FLINK-17211 Project: Flink

[jira] [Created] (FLINK-17210) Implement database DDLs for Hive dialect

Rui Li created FLINK-17210: -- Summary: Implement database DDLs for Hive dialect Key: FLINK-17210 URL: https://issues.apache.org/jira/browse/FLINK-17210 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Switch to Azure Pipelines as the primary CI tool / switch off Travis

I am in favour of decommissioning Travis. Moreover, I wanted to use this thread to raise another issue with Travis that I have discovered recently; many of the builds running in my private Travis account are timing out in the compilation stage (i.e., compilation takes more than 50 minutes). This

Re: [jira] [Commented] (FLINK-17200) Add connectors to ClickHouse

We discussed splitting the project not too long ago and decided against it due to maintenance overhead. In any case the Flink project does not have the capacity to maintain every connector. Frequently it happened that there was only 1 contributor working on a connector, at which point the

Re: [jira] [Commented] (FLINK-17200) Add connectors to ClickHouse

@Dawid @dev Can we separate the flink-connectors project so that we can support more connectors in the future? Like this jira：Add connectors to ClickHouse Best Regards jinhai...@gmail.com > 2020年4月17日 下午3:07，Dawid Wysakowicz (Jira) 写道： > > >[ >

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations Hequn! Stephan Ewen 于2020年4月17日周五 下午3:42写道： > Congrats! > > On Fri, Apr 17, 2020 at 9:40 AM Jark Wu wrote: > > > Congratulations Hequn! > > > > Best, > > Jark > > > > On Fri, 17 Apr 2020 at 15:32, Yangze Guo wrote: > > > > > Congratulations! > > > > > > Best, > > > Yangze Guo

[jira] [Created] (FLINK-17209) Allow users to specify dialect in sql-client yaml

Rui Li created FLINK-17209: -- Summary: Allow users to specify dialect in sql-client yaml Key: FLINK-17209 URL: https://issues.apache.org/jira/browse/FLINK-17209 Project: Flink Issue Type: Sub-task

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congrats! On Fri, Apr 17, 2020 at 9:40 AM Jark Wu wrote: > Congratulations Hequn! > > Best, > Jark > > On Fri, 17 Apr 2020 at 15:32, Yangze Guo wrote: > > > Congratulations! > > > > Best, > > Yangze Guo > > > > On Fri, Apr 17, 2020 at 3:19 PM Jeff Zhang wrote: > > > > > > Congratulations,

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations Hequn! Best, Jark On Fri, 17 Apr 2020 at 15:32, Yangze Guo wrote: > Congratulations! > > Best, > Yangze Guo > > On Fri, Apr 17, 2020 at 3:19 PM Jeff Zhang wrote: > > > > Congratulations, Hequn! > > > > Paul Lam 于2020年4月17日周五 下午3:02写道： > > > > > Congrats Hequn! Thanks a lot

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations! Best, Yangze Guo On Fri, Apr 17, 2020 at 3:19 PM Jeff Zhang wrote: > > Congratulations, Hequn! > > Paul Lam 于2020年4月17日周五 下午3:02写道： > > > Congrats Hequn! Thanks a lot for your contribution to the community! > > > > Best, > > Paul Lam > > > > Dian Fu 于2020年4月17日周五 下午2:58写道： >

Re: [PROPOSAL] Google Season of Docs 2020.

Thanks a lot for volunteering to drive an application for the Flink project! Last year, we discussed finishing the chinese translation as a potential project. I believe there's still a need for this. Since the work on the project starts pretty far in the future (September), the translation

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations, Hequn! Paul Lam 于2020年4月17日周五 下午3:02写道： > Congrats Hequn! Thanks a lot for your contribution to the community! > > Best, > Paul Lam > > Dian Fu 于2020年4月17日周五 下午2:58写道： > > > Congratulations, Hequn! > > > > > 在 2020年4月17日，下午2:36，Becket Qin 写道： > > > > > > Hi all, > > > > > > I

Re: [PROPOSAL] Google Season of Docs 2020.

Hi Marta, Thanks for kicking off the discussion. Aljoscha has recently revived the implementation of the FLIP-42 and has already moved things around quite a bit. [1] There are a lot of areas that can be improved of course, but a lot of them require very deep knowledge about the system (e.g. the

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations, Hequn, and thanks for your work for community ~ Best, Danny Chan 在 2020年4月17日 +0800 PM2:44，Becket Qin ，写道： > Hi all, > > I am glad to announce that Hequn Chen has joined the Flink PMC. > > Hequn has contributed to Flink for years. He has worked on several > components including

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congrats Hequn! Thanks a lot for your contribution to the community! Best, Paul Lam Dian Fu 于2020年4月17日周五 下午2:58写道： > Congratulations, Hequn! > > > 在 2020年4月17日，下午2:36，Becket Qin 写道： > > > > Hi all, > > > > I am glad to announce that Hequn Chen has joined the Flink PMC. > > > > Hequn has

Re: [ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Congratulations, Hequn! > 在 2020年4月17日，下午2:36，Becket Qin 写道： > > Hi all, > > I am glad to announce that Hequn Chen has joined the Flink PMC. > > Hequn has contributed to Flink for years. He has worked on several > components including Table / SQL，PyFlink and Flink ML Pipeline. Besides, >

[ANNOUNCE] New Apache Flink PMC Member - Hequn Chen

Hi all, I am glad to announce that Hequn Chen has joined the Flink PMC. Hequn has contributed to Flink for years. He has worked on several components including Table / SQL，PyFlink and Flink ML Pipeline. Besides, Hequn is also very active in the community since the beginning. Congratulations,

[jira] [Created] (FLINK-17208) Reduce redundant data available notification of PipelinedSubpartition

Yingjie Cao created FLINK-17208: --- Summary: Reduce redundant data available notification of PipelinedSubpartition Key: FLINK-17208 URL: https://issues.apache.org/jira/browse/FLINK-17208 Project: Flink

[jira] [Created] (FLINK-17206) Refactor FunctionCatalog to support delayed UDF initialization.

Wei Zhong created FLINK-17206: - Summary: Refactor FunctionCatalog to support delayed UDF initialization. Key: FLINK-17206 URL: https://issues.apache.org/jira/browse/FLINK-17206 Project: Flink

[jira] [Created] (FLINK-17207) Lots of test_ci Python tests failing with OSError: [Errno 9] Bad file descriptor

Piotr Nowojski created FLINK-17207: -- Summary: Lots of test_ci Python tests failing with OSError: [Errno 9] Bad file descriptor Key: FLINK-17207 URL: https://issues.apache.org/jira/browse/FLINK-17207

[jira] [Created] (FLINK-17205) test_ci Python fails with unable to execute 'gcc': No such file or directory

Piotr Nowojski created FLINK-17205: -- Summary: test_ci Python fails with unable to execute 'gcc': No such file or directory Key: FLINK-17205 URL: https://issues.apache.org/jira/browse/FLINK-17205

[jira] [Created] (FLINK-17204) The RMQSource and RMQSink of the RabbitMQ connector have inconsistent default value of durable ​​when declaring the queue.

ChaojianZhang created FLINK-17204: - Summary: The RMQSource and RMQSink of the RabbitMQ connector have inconsistent default value of durable ​​when declaring the queue. Key: FLINK-17204 URL:

Re: [jira] [Created] (FLINK-17202) Add SQL for ClickHouse connector

Add Table API and SQL for ClickHouse connector is a better description > 在 2020年4月17日，下午1:43，jinhai (Jira) 写道： > > jinhai created FLINK-17202: > -- > > Summary: Add SQL for ClickHouse connector > Key: FLINK-17202 > URL: