Integration of DataSketches into Flink

Hello All, I am a committer on DataSketches.apache.org and just learning about Flink, Since Flink is designed for stateful stream processing I would think it would make sense to have the DataSketches library integrated into its core so all users of Flink could ta

[jira] [Created] (FLINK-17386) Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided.

Wenlong Lyu created FLINK-17386: --- Summary: Exception in HadoopSecurityContextFactory.createContext while no shaded-hadoop-lib provided. Key: FLINK-17386 URL: https://issues.apache.org/jira/browse/FLINK-17386

[jira] [Created] (FLINK-17385) Fix precision problem when converting JDBC numberic into Flink decimal type

Jark Wu created FLINK-17385: --- Summary: Fix precision problem when converting JDBC numberic into Flink decimal type Key: FLINK-17385 URL: https://issues.apache.org/jira/browse/FLINK-17385 Project: Flink

[jira] [Created] (FLINK-17384) support read hbase conf dir from flink.conf just like hadoop_conf

jackylau created FLINK-17384: Summary: support read hbase conf dir from flink.conf just like hadoop_conf Key: FLINK-17384 URL: https://issues.apache.org/jira/browse/FLINK-17384 Project: Flink Is

[jira] [Created] (FLINK-17383) flink legacy planner should not use CollectionEnvironment any more

godfrey he created FLINK-17383: -- Summary: flink legacy planner should not use CollectionEnvironment any more Key: FLINK-17383 URL: https://issues.apache.org/jira/browse/FLINK-17383 Project: Flink

Re: [ANNOUNCE] Apache Flink 1.9.3 released

Thanks for your great job, Dian! Best, Jincheng Hequn Cheng 于2020年4月25日周六 下午8:30写道： > @Dian, thanks a lot for the release and for being the release manager. > Also thanks to everyone who made this release possible! > > Best, > Hequn > > On Sat, Apr 25, 2020 at 7:57 PM Dian Fu wrote: > >> Hi e

Re: [DISCUSS] FLIP-36 - Support Interactive Programming in Flink Table API

Hi Becket, You are right. It makes sense to treat retry of job 2 as an ordinary job. And the config does introduce some unnecessary confusion. Thank you for you comment. I will update the FLIP. Best, Xuannan On Sat, Apr 25, 2020 at 7:44 AM Becket Qin wrote: > Hi Xuannan, > > If user submits Jo

Re: [DISCUSS] Exact feature freeze date

+1 for extending the feature freeze to May 15th. Best Regards, Yu On Fri, 24 Apr 2020 at 14:43, Yuan Mei wrote: > +1 > > On Thu, Apr 23, 2020 at 4:10 PM Stephan Ewen wrote: > > > Hi all! > > > > I want to bring up a discussion about when we want to do the feature > freeze > > for 1.11. > > >

Re: Unable to self-assign issue

Hi Manish, Thanks for being interested in contributing to Flink! It is our bylaw that only committers can assign a JIRA ticket [1] and you could find the reason behind it in this ML discussion [2]. For FLINK-17376, since there's already a discussion and conclusion in ML [3], I think it's ok to s

[jira] [Created] (FLINK-17382) Flink should support dynamic log level setting

Xingxing Di created FLINK-17382: --- Summary: Flink should support dynamic log level setting Key: FLINK-17382 URL: https://issues.apache.org/jira/browse/FLINK-17382 Project: Flink Issue Type: New

Re: [DISCUSS] Removing deprecated state methods in 1.11

+1 (belated), removing long deprecated codes help keep the code base clean and reduce the maintenance efforts. Best Regards, Yu On Sat, 25 Apr 2020 at 00:45, Stephan Ewen wrote: > I'll turn this into a ticket for 1.11 then. > > Thanks! > > On Thu, Apr 23, 2020 at 4:13 PM Aljoscha Krettek > wr

[jira] [Created] (FLINK-17381) travis_controller prints wrong mvn version

Benchao Li created FLINK-17381: -- Summary: travis_controller prints wrong mvn version Key: FLINK-17381 URL: https://issues.apache.org/jira/browse/FLINK-17381 Project: Flink Issue Type: Improvemen

Unable to self-assign issue

Hi, I want to assign issue 17376 to me, but it seems I don't have rights to do it. Manish

[jira] [Created] (FLINK-17380) runAllDeletesTest: "Memory records is not writable"

Robert Metzger created FLINK-17380: -- Summary: runAllDeletesTest: "Memory records is not writable" Key: FLINK-17380 URL: https://issues.apache.org/jira/browse/FLINK-17380 Project: Flink Issue

[jira] [Created] (FLINK-17379) testScaleDownBeforeFirstCheckpoint Error reading field 'api_versions': Error reading field 'max_version':

Robert Metzger created FLINK-17379: -- Summary: testScaleDownBeforeFirstCheckpoint Error reading field 'api_versions': Error reading field 'max_version': Key: FLINK-17379 URL: https://issues.apache.org/jira/browse

Re: [ANNOUNCE] Apache Flink 1.9.3 released

@Dian, thanks a lot for the release and for being the release manager. Also thanks to everyone who made this release possible! Best, Hequn On Sat, Apr 25, 2020 at 7:57 PM Dian Fu wrote: > Hi everyone, > > The Apache Flink community is very happy to announce the release of Apache > Flink 1.9.3,

Re: New contributor

welcome, Etienne Best, Forward Hequn Cheng 于2020年4月25日周六 下午8:23写道： > Welcome, Etienne :) > > Best, > Hequn > > On Fri, Apr 24, 2020 at 10:04 PM Etienne Chauchot > wrote: > > > Hi Till, > > > > Looking forward too ... > > > > Thanks > > > > Etienne > > > > On 24/04/2020 15:09, Till Rohrmann wro

[jira] [Created] (FLINK-17378) KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable

Robert Metzger created FLINK-17378: -- Summary: KafkaProducerExactlyOnceITCase>KafkaProducerTestBase.testExactlyOnceCustomOperator unstable Key: FLINK-17378 URL: https://issues.apache.org/jira/browse/FLINK-17378

Re: New contributor

Welcome, Etienne :) Best, Hequn On Fri, Apr 24, 2020 at 10:04 PM Etienne Chauchot wrote: > Hi Till, > > Looking forward too ... > > Thanks > > Etienne > > On 24/04/2020 15:09, Till Rohrmann wrote: > > Hi Etienne, > > > > welcome to the Flink community. Looking forward to working with you on > >

[jira] [Created] (FLINK-17377) support variable substitution

Guangbin Zhu created FLINK-17377: Summary: support variable substitution Key: FLINK-17377 URL: https://issues.apache.org/jira/browse/FLINK-17377 Project: Flink Issue Type: New Feature

[ANNOUNCE] Apache Flink 1.9.3 released

Hi everyone, The Apache Flink community is very happy to announce the release of Apache Flink 1.9.3, which is the third bugfix release for the Apache Flink 1.9 series. Apache Flink® is an open-source stream processing framework for distributed, high-performing, always-available, and accurate data

How to reproduce the issue locally

Hi, While working on an issue, is there a specific approach to quickly reproduce the issue locally? With regards Manish

Re: Contributor

Hi, Welcome to the community! There is no contributor permission now, and you can just create the issue and ping a committer to ask to be assigned. BTW, there is a document about how to contribute[1]. [1] https://flink.apache.org/contributing/how-to-contribute.html 流动的联系 <1060591...@qq.com> 于202