[jira] [Created] (FLINK-28619) flink sql window aggregation using early fire will produce empty data

2022-07-20 Thread simenliuxing (Jira)
simenliuxing created FLINK-28619: Summary: flink sql window aggregation using early fire will produce empty data Key: FLINK-28619 URL: https://issues.apache.org/jira/browse/FLINK-28619 Project: Flink

Re: [DISCUSS] Replace Attempt column with Attempt Number on the subtask list page of the Web UI

2022-07-20 Thread Gen Luo
Hi user mail list, I'm also forwarding this thread to you. Please let me know if you have any comments or feedback! Best, Gen On Wed, Jul 20, 2022 at 4:25 PM Zhu Zhu wrote: > Thanks for starting this discussion, Gen! > I agree it is confusing or even troublesome to show an attempt id that is >

[jira] [Created] (FLINK-28618) Cannot use hive.dialect on master

2022-07-20 Thread liubo (Jira)
liubo created FLINK-28618: - Summary: Cannot use hive.dialect on master Key: FLINK-28618 URL: https://issues.apache.org/jira/browse/FLINK-28618 Project: Flink Issue Type: Bug Components: Co

[jira] [Created] (FLINK-28617) Support stop job statement in SqlGatewayService

2022-07-20 Thread Paul Lin (Jira)
Paul Lin created FLINK-28617: Summary: Support stop job statement in SqlGatewayService Key: FLINK-28617 URL: https://issues.apache.org/jira/browse/FLINK-28617 Project: Flink Issue Type: Sub-task

RE: [VOTE] FLIP-251: Support collecting arbitrary number of streams

2022-07-20 Thread Roc Marshal
+1. (Non-binding) Thanks for driving this. Best Roc Marshal On 2022/07/19 08:26:15 Chesnay Schepler wrote: > I'd like to proceed with the vote for FLIP-251 [1], as no objections or > issues were raised in [2]. > > The vote will last for at least 72 hours unless there is an objection or > insuff

Re: [DISCUSS] FLIP-217 Support watermark alignment of source splits

2022-07-20 Thread Thomas Weise
Hi Sebastian, Thank you for updating the FLIP and sorry for my delayed response. As Piotr pointed out, we would need to incorporate the fallback flag into the design to reflect the outcome of the previous discussion. Based on the current FLIP and as detailed by Becket, the SourceOperator coordina

[GitHub] [flink-connector-redis] knaufk commented on pull request #2: [FLINK-15571][connector][WIP] Redis Stream connector for Flink

2022-07-20 Thread GitBox
knaufk commented on PR #2: URL: https://github.com/apache/flink-connector-redis/pull/2#issuecomment-1190766247 Thanks @sazzad16 for you contribution and patience. I think the community would really benefit from a Redis Connector and I'll try to help you get this in. The main challe

Re: [VOTE] FLIP-252: Amazon DynamoDB Sink Connector

2022-07-20 Thread Konstantin Knauf
+1. Thanks! Am Mi., 20. Juli 2022 um 16:48 Uhr schrieb Tzu-Li (Gordon) Tai < tzuli...@apache.org>: > +1 > > On Wed, Jul 20, 2022 at 6:13 AM Danny Cranmer > wrote: > > > Hi there, > > > > After the discussion in [1], I’d like to open a voting thread for > FLIP-252 > > [2], which proposes the addi

Re: [VOTE] FLIP-251: Support collecting arbitrary number of streams

2022-07-20 Thread Konstantin Knauf
+1 (binding) Am Mi., 20. Juli 2022 um 15:48 Uhr schrieb David Anderson < dander...@apache.org>: > +1 > > Thank you Chesnay. > > On Tue, Jul 19, 2022 at 3:09 PM Alexander Fedulov > > wrote: > > > +1 > > Looking forward to using the API to simplify tests setups. > > > > Best, > > Alexander Fedulov

[DISCUSS] FLIP-246: Multi Cluster Kafka Source

2022-07-20 Thread Mason Chen
Hi all, We would like to start a discussion thread on FLIP-246: Multi Cluster Kafka Source [1] where we propose to provide a source connector for dynamically reading from Kafka multiple clusters, which will not require Flink job restart. This can greatly improve the Kafka migration experience for

[jira] [Created] (FLINK-28616) Quickstart and examples docs should use configured stable version

2022-07-20 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-28616: -- Summary: Quickstart and examples docs should use configured stable version Key: FLINK-28616 URL: https://issues.apache.org/jira/browse/FLINK-28616 Project: Flink

[jira] [Created] (FLINK-28615) Add K8s recommend labels to the deployments, services created by operator

2022-07-20 Thread Xin Hao (Jira)
Xin Hao created FLINK-28615: --- Summary: Add K8s recommend labels to the deployments, services created by operator Key: FLINK-28615 URL: https://issues.apache.org/jira/browse/FLINK-28615 Project: Flink

Re: [VOTE] Apache Flink Kubernetes Operator Release 1.1.0, release candidate #1

2022-07-20 Thread Geng Biao
Hi there, Thanks a lot for the release! +1 (non-binding) Successfully verified the following: - Checksums and gpg signatures of the tar files. - No binaries in source release - Build from source, build image from source - Helm Repo works, Helm install works - Submit example applications without

Re: [VOTE] FLIP-252: Amazon DynamoDB Sink Connector

2022-07-20 Thread Tzu-Li (Gordon) Tai
+1 On Wed, Jul 20, 2022 at 6:13 AM Danny Cranmer wrote: > Hi there, > > After the discussion in [1], I’d like to open a voting thread for FLIP-252 > [2], which proposes the addition of an Amazon DynamoDB sink based on the > Async Sink [3]. > > The vote will be open until July 23rd earliest (72h)

Re: [VOTE] FLIP-251: Support collecting arbitrary number of streams

2022-07-20 Thread David Anderson
+1 Thank you Chesnay. On Tue, Jul 19, 2022 at 3:09 PM Alexander Fedulov wrote: > +1 > Looking forward to using the API to simplify tests setups. > > Best, > Alexander Fedulov > > On Tue, Jul 19, 2022 at 2:31 PM Martijn Visser > wrote: > > > Thanks for creating the FLIP and opening the vote Che

Re: [DISCUSS] FLIP-252: Amazon DynamoDB Sink Connector

2022-07-20 Thread Danny Cranmer
Thanks for the feedback and support Robert. I have created a vote thread [1] Danny Cranmer [1] https://lists.apache.org/thread/4qq33hxfjf5ms21pbo4mk2q7xn4s2l0h On Wed, Jul 20, 2022 at 7:19 AM Robert Metzger wrote: > Thanks a lot for this nice proposal! > > DynamoDB seems to be a connector that

[VOTE] FLIP-252: Amazon DynamoDB Sink Connector

2022-07-20 Thread Danny Cranmer
Hi there, After the discussion in [1], I’d like to open a voting thread for FLIP-252 [2], which proposes the addition of an Amazon DynamoDB sink based on the Async Sink [3]. The vote will be open until July 23rd earliest (72h), unless there are any binding vetos. Cheers, Danny [1] https://lists

Re: [ANNOUNCE] Table Store release-0.2 branch cut

2022-07-20 Thread Shuo Cheng
Awesome! Looking forward to the release. Best, Shuo On Wed, Jul 20, 2022 at 3:12 PM Leonard Xu wrote: > Thanks Jinsong for the great work, look forward to the release. > > Best, > Leonard > > > 2022年7月20日 下午2:50,Jingsong Li 写道: > > > > Hi Flink devs! > > > > The version on the main branch has

[VOTE] Apache Flink Kubernetes Operator Release 1.1.0, release candidate #1

2022-07-20 Thread Gyula Fóra
Hi everyone, Please review and vote on the release candidate #1 for the version 1.1.0 of Apache Flink Kubernetes Operator, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release (please provide specific comments) **Release Overview** As an overview, the release consists of th

Re: [DISCUSS] FLIP-247 Bulk fetch of table and column statistics for given partitions

2022-07-20 Thread Jark Wu
I agree with Jingsong. There are use cases to get partitions and partition stats in a single call to reduce the IO cost. For example, extending Catalog#listPartitions to Catalog#listPartitionsWithStats, and extending Catalog#listPartitionsByFilter to Catalog#listPartitionsWithStatsByFilter. This a

Re: [DISCUSS] FLIP-247 Bulk fetch of table and column statistics for given partitions

2022-07-20 Thread Jingsong Li
Thanks for your reply. - Consider bulkGetPartitionStatistics, partition statistics are already in HiveMetastoreClient.listPartitions. But on our side, we need Catalog.getPartitions first, and then Catalog.bulkGetPartitionStatistics. - Consider bulkGetPartitionColumnStatistics, yes, as you said, w

Re: [DISCUSS] Replace Attempt column with Attempt Number on the subtask list page of the Web UI

2022-07-20 Thread Zhu Zhu
Thanks for starting this discussion, Gen! I agree it is confusing or even troublesome to show an attempt id that is different from the corresponding attempt number in REST, metrics and logs. It adds burden to users to do the mapping in troubleshooting. Mis-mapping can be easy to happen and result i

Re: [DISCUSS] FLIP-247 Bulk fetch of table and column statistics for given partitions

2022-07-20 Thread Jing Ge
Hi Jingsong, Thanks for clarifying it. Are you suggesting a new method or changing the name of the methods described in the FLIP? Please see my answers and further questions below. Best regards, Jing On Wed, Jul 20, 2022 at 4:28 AM Jingsong Li wrote: > Hi Jing, > > I understand that the statis

[DISCUSS] Replace Attempt column with Attempt Number on the subtask list page of the Web UI

2022-07-20 Thread Gen Luo
Hi everyone, I'd like to propose a change on the Web UI to replace the Attempt column with an Attempt Number column on the subtask list page. >From the very beginning, the attempt number shown is calculated at the frontend by subtask.attempt + 1, which means the attempt number shown on the web UI

Re: [ANNOUNCE] Table Store release-0.2 branch cut

2022-07-20 Thread Leonard Xu
Thanks Jinsong for the great work, look forward to the release. Best, Leonard > 2022年7月20日 下午2:50,Jingsong Li 写道: > > Hi Flink devs! > > The version on the main branch has been updated to 0.3-SNAPSHOT. > > The release-0.2 branch has been forked from main: > https://github.com/apache/flink-tab