[jira] [Created] (FLINK-18667) Data Types documentation misunderstand users

Jingsong Lee created FLINK-18667: Summary: Data Types documentation misunderstand users Key: FLINK-18667 URL: https://issues.apache.org/jira/browse/FLINK-18667 Project: Flink Issue Type: New

Re: Flink Redis connectivity

Hi Ramya Have you ever tried flink-connector-redis in bahir [1][2]? I think you could use it or obtain some insights. [1] http://bahir.apache.org/docs/flink/current/flink-streaming-redis/ [2]

[jira] [Created] (FLINK-18666) Update japicmp configuration for 1.11.1

Dian Fu created FLINK-18666: --- Summary: Update japicmp configuration for 1.11.1 Key: FLINK-18666 URL: https://issues.apache.org/jira/browse/FLINK-18666 Project: Flink Issue Type: Task

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

Congratulations! Best, Godfrey Till Rohrmann 于2020年7月21日周二 下午10:46写道： > Congrats, Piotr! > > Cheers, > Till > > On Thu, Jul 9, 2020 at 4:15 AM Xingcan Cui wrote: > > > Congratulations, Piotr! > > > > Best, Xingcan > > > > On Wed, Jul 8, 2020, 21:53 Yang Wang wrote: > > > > > Congratulations

Re: thrift support

Thanks for the discussion. In https://github.com/apache/flink/pull/8067 we made an initial version on adding thrift-format support in flink, and haven't got time to finish it. Feel free to take it over and make changes. I've also linked this discussion thread in

[jira] [Created] (FLINK-18665) Filesystem connector should use TableSchema exclude computed columns

Jark Wu created FLINK-18665: --- Summary: Filesystem connector should use TableSchema exclude computed columns Key: FLINK-18665 URL: https://issues.apache.org/jira/browse/FLINK-18665 Project: Flink

Re: [ANNOUNCE] New PMC member: Piotr Nowojski

Congrats, Piotr! Cheers, Till On Thu, Jul 9, 2020 at 4:15 AM Xingcan Cui wrote: > Congratulations, Piotr! > > Best, Xingcan > > On Wed, Jul 8, 2020, 21:53 Yang Wang wrote: > > > Congratulations Piotr! > > > > > > Best, > > Yang > > > > Dan Zou 于2020年7月8日周三 下午10:36写道： > > > > >

Re: [ANNOUNCE] Apache Flink 1.11.0 released

Thanks a lot for being our release managers Zhijiang and Piotr and thanks to everyone who helped making this release possible. Cheers, Till On Wed, Jul 8, 2020 at 10:59 AM godfrey he wrote: > Congratulations! > > Thanks Zhijiang and Piotr for the great work, and thanks everyone for > their

[jira] [Created] (FLINK-18664) Publish Dockerfiles for release 1.11.1

Dian Fu created FLINK-18664: --- Summary: Publish Dockerfiles for release 1.11.1 Key: FLINK-18664 URL: https://issues.apache.org/jira/browse/FLINK-18664 Project: Flink Issue Type: Task

[jira] [Created] (FLINK-18663) Fix Flink On YARN AM not exit

tartarus created FLINK-18663: Summary: Fix Flink On YARN AM not exit Key: FLINK-18663 URL: https://issues.apache.org/jira/browse/FLINK-18663 Project: Flink Issue Type: Bug Components:

Re: Flink Redis connectivity

Hi, I think you could implement `RichMapFunction` and create `redisClient` in the `open` method. Best, Yangze Guo On Tue, Jul 21, 2020 at 6:43 PM Ramya Ramamurthy wrote: > > Hi, > > As per the understanding we have from the documentation, I guess its not > possible to take the redis connection

Flink Redis connectivity

Hi, As per the understanding we have from the documentation, I guess its not possible to take the redis connection within the Data Stream. In that case, how should i proceed ? How can i access a DB client object within the stream ?? I am using Flink 1.7. any help here would be appreciated.

[jira] [Created] (FLINK-18662) Provide more detailed metrics why unaligned checkpoint is taking long time

Piotr Nowojski created FLINK-18662: -- Summary: Provide more detailed metrics why unaligned checkpoint is taking long time Key: FLINK-18662 URL: https://issues.apache.org/jira/browse/FLINK-18662

[jira] [Created] (FLINK-18661) [Kinesis][EFO] Stream consumer Registration/Deregistration

Danny Cranmer created FLINK-18661: - Summary: [Kinesis][EFO] Stream consumer Registration/Deregistration Key: FLINK-18661 URL: https://issues.apache.org/jira/browse/FLINK-18661 Project: Flink

[jira] [Created] (FLINK-18660) Bump netty to 4.1.51

Chesnay Schepler created FLINK-18660: Summary: Bump netty to 4.1.51 Key: FLINK-18660 URL: https://issues.apache.org/jira/browse/FLINK-18660 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-18659) FileNotFoundException when writing Hive orc tables

Jingsong Lee created FLINK-18659: Summary: FileNotFoundException when writing Hive orc tables Key: FLINK-18659 URL: https://issues.apache.org/jira/browse/FLINK-18659 Project: Flink Issue

[jira] [Created] (FLINK-18658) MiniClusterResource does not forward RpcServiceSharing setting

Chesnay Schepler created FLINK-18658: Summary: MiniClusterResource does not forward RpcServiceSharing setting Key: FLINK-18658 URL: https://issues.apache.org/jira/browse/FLINK-18658 Project:

[jira] [Created] (FLINK-18657) Change semantics of DESCRIBE SELECT statement

Fabian Hueske created FLINK-18657: - Summary: Change semantics of DESCRIBE SELECT statement Key: FLINK-18657 URL: https://issues.apache.org/jira/browse/FLINK-18657 Project: Flink Issue Type:

Re: thrift support

Thanks Dawid for the link. I have a glance at the PR. I think we can continue the thrift format based on the PR (would be better to reach out to the author). Best, Jark On Tue, 21 Jul 2020 at 15:58, Dawid Wysakowicz wrote: > Hi, > > I've just spotted this PR that might be helpful in the

[jira] [Created] (FLINK-18656) Start Delay metric is always zero for unaligned checkpoints

Piotr Nowojski created FLINK-18656: -- Summary: Start Delay metric is always zero for unaligned checkpoints Key: FLINK-18656 URL: https://issues.apache.org/jira/browse/FLINK-18656 Project: Flink

Re: thrift support

Hi, I've just spotted this PR that might be helpful in the discussion: https://github.com/apache/flink/pull/8067 Best, Dawid On 20/07/2020 04:30, Benchao Li wrote: > Hi Chen, > > Thanks for bringing up this discussion. We are doing something similar > internally recently. > > Our use case is

Re: [RESULT][VOTE] Release 1.11.1, release candidate #1

Thank you Dian for carrying out the vote! :) Piotrek wt., 21 lip 2020 o 07:28 Dian Fu napisał(a): > Hi everyone, > > I'm happy to announce that we have unanimously approved this release. > > There are 9 approving votes, 4 of which are binding: > * Jark (binding) > * Yu (binding) > * Zhijiang

Re: subscribe dev mail list

Hi, Jake Just send email to dev-subscr...@flink.apache.org if you want to subscribe the mail from dev@flink.apache.org , and you can refer[1] for more details. Best, Leonard Xu

Re: subscribe dev mail list

Hi Jake, To subscribe, please send an email to dev-subscr...@flink.apache.org. If you have any questions, you can find more detailed instructions in [1]. [1] https://flink.apache.org/community.html#how-to-subscribe-to-a-mailing-list Best, Yangze Guo On Tue, Jul 21, 2020 at 2:49 PM Jake wrote:

subscribe dev mail list

It is very pleased to write to you! www.myteek.com Jake Zhang ??