[jira] [Created] (FLINK-30409) Support reopening closed metric groups

2022-12-13 Thread Mason Chen (Jira)
Mason Chen created FLINK-30409: -- Summary: Support reopening closed metric groups Key: FLINK-30409 URL: https://issues.apache.org/jira/browse/FLINK-30409 Project: Flink Issue Type: Improvement

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

2022-12-13 Thread Őrhidi Mátyás
Hi Devs! I'm happy to announce that we have unanimously approved this release. There are 6 approving votes, 3 of which are binding: - Marton Balassi (binding) - Max Michels (binding) - Gyula Fora (binding) - Jim Busche (non-binding) - Ted Chang (non-binding)

[jira] [Created] (FLINK-30408) Add unit test for HA metadata check logic

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30408: -- Summary: Add unit test for HA metadata check logic Key: FLINK-30408 URL: https://issues.apache.org/jira/browse/FLINK-30408 Project: Flink Issue Type:

[jira] [Created] (FLINK-30407) Better encapsulate error handling logic in controllers

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30407: -- Summary: Better encapsulate error handling logic in controllers Key: FLINK-30407 URL: https://issues.apache.org/jira/browse/FLINK-30407 Project: Flink Issue

[jira] [Created] (FLINK-30406) Jobmanager Deployment error without HA metadata should not lead to unrecoverable error

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30406: -- Summary: Jobmanager Deployment error without HA metadata should not lead to unrecoverable error Key: FLINK-30406 URL: https://issues.apache.org/jira/browse/FLINK-30406

[jira] [Created] (FLINK-30405) Add ResourceLifecycleStatus to CommonStatus and printer column

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30405: -- Summary: Add ResourceLifecycleStatus to CommonStatus and printer column Key: FLINK-30405 URL: https://issues.apache.org/jira/browse/FLINK-30405 Project: Flink

[jira] [Created] (FLINK-30404) Do not redeploy taskmanagers on standalone application scaling

2022-12-13 Thread Gyula Fora (Jira)
Gyula Fora created FLINK-30404: -- Summary: Do not redeploy taskmanagers on standalone application scaling Key: FLINK-30404 URL: https://issues.apache.org/jira/browse/FLINK-30404 Project: Flink

Re: [DISCUSS] FLIP-277: Native GlueCatalog Support in Flink

2022-12-13 Thread Danny Cranmer
Hello Samrat, Sorry for the late response. +1 for a native Glue Data Catalog integration. We have internally developed a Glue Data Catalog catalog implementation that shims hive. We have been meaning to contribute, but this solution can replace our internal one. +1 for putting this in the

[jira] [Created] (FLINK-30403) The reported latest completed checkpoint is discarded

2022-12-13 Thread Zdenek Tison (Jira)
Zdenek Tison created FLINK-30403: Summary: The reported latest completed checkpoint is discarded Key: FLINK-30403 URL: https://issues.apache.org/jira/browse/FLINK-30403 Project: Flink Issue

[jira] [Created] (FLINK-30402) Separate token framework generic and hadoop specific parts

2022-12-13 Thread Gabor Somogyi (Jira)
Gabor Somogyi created FLINK-30402: - Summary: Separate token framework generic and hadoop specific parts Key: FLINK-30402 URL: https://issues.apache.org/jira/browse/FLINK-30402 Project: Flink

[jira] [Created] (FLINK-30401) Add Estimator and Transformer for MinHashLSH

2022-12-13 Thread Fan Hong (Jira)
Fan Hong created FLINK-30401: Summary: Add Estimator and Transformer for MinHashLSH Key: FLINK-30401 URL: https://issues.apache.org/jira/browse/FLINK-30401 Project: Flink Issue Type: New Feature

Re: [DISCUSS] FLIP-276: Data Consistency of Streaming and Batch ETL in Flink and Table Store

2022-12-13 Thread Piotr Nowojski
Hi Shammon, Thanks for the explanations, I think I understand the problem better now. I have a couple of follow up questions, but first: >> 3. I'm pretty sure there are counter examples, where your proposed mechanism of using checkpoints (even aligned!) will produce inconsistent data from the

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

2022-12-13 Thread Gyula Fóra
+1 (binding) - Verified source, helm release and signatures - Docs, javadocs look good - Helm chart points to correct image, installed locally from helm repo and run some apps - Maven repo contents look clean and correct - Checked release notes on JIRA Looks great Matyas, awesome work! Cheers

[VOTE] Release flink-connector-pulsar, release candidate #3

2022-12-13 Thread Martijn Visser
Hi everyone, Please review and vote on the release candidate #3 for the version 3.0.0, 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], *

[VOTE] Release flink-connector-rabbitmq, release candidate #1

2022-12-13 Thread Martijn Visser
Hi everyone, Please review and vote on the release candidate #1 for the version 3.0.0, 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], *

[jira] [Created] (FLINK-30400) Stop bundling connector-base in externalized connectors

2022-12-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30400: Summary: Stop bundling connector-base in externalized connectors Key: FLINK-30400 URL: https://issues.apache.org/jira/browse/FLINK-30400 Project: Flink

[jira] [Created] (FLINK-30399) Enable connectors to use config docs generator

2022-12-13 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-30399: Summary: Enable connectors to use config docs generator Key: FLINK-30399 URL: https://issues.apache.org/jira/browse/FLINK-30399 Project: Flink Issue

Re: [VOTE] Release flink-connector-pulsar v3.0.0, release candidate #2

2022-12-13 Thread Martijn Visser
Thanks Chesnay. Cancelling the RC and will create another one On Tue, Dec 13, 2022 at 11:46 AM Chesnay Schepler wrote: > -1 > > The source release does not contain a LICENSE or NOTICE file. > > > On 12/12/2022 20:06, Martijn Visser wrote: > > Hi everyone, > > Please review and vote on the

Re: [VOTE] Release flink-connector-pulsar v3.0.0, release candidate #2

2022-12-13 Thread Chesnay Schepler
-1 The source release does not contain a LICENSE or NOTICE file. On 12/12/2022 20:06, Martijn Visser wrote: Hi everyone, Please review and vote on the release candidate #2 for the flink-connector-pulsar version v3.0.0, as follows: [ ] +1, Approve the release [ ] -1, Do not approve the release

[jira] [Created] (FLINK-30398) Introduce S3 support for table store

2022-12-13 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-30398: Summary: Introduce S3 support for table store Key: FLINK-30398 URL: https://issues.apache.org/jira/browse/FLINK-30398 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-30397) Remove Pulsar connector from master branch

2022-12-13 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-30397: -- Summary: Remove Pulsar connector from master branch Key: FLINK-30397 URL: https://issues.apache.org/jira/browse/FLINK-30397 Project: Flink Issue Type:

[SUMMARY] Flink 1.17 Release Sync 12/13/2022

2022-12-13 Thread Leonard Xu
Hi devs and users, I’d like to share the highlights about the 1.17 release sync on 12/13/2022. - Release tracking page: - 1.17 development is moving forward [1], we have 5 weeks remaining - @committers Please continuously update the the progress in the 1.17 page - Externalized

Re: [DISCUSS] FLIP-275: Support Remote SQL Client Based on SQL Gateway

2022-12-13 Thread yu zelin
Hi everyone, Sorry for the incorrect message in my last email. I want to start the vote on Wednesday as long as there are no questions in this period. Best, Yu Zelin On Tue, Dec 13, 2022 at 5:08 PM yu zelin wrote: > Hi, everyone, > > Looks like our new design is similar to Timo’s suggestion,

Re: [DISCUSS] FLIP-275: Support Remote SQL Client Based on SQL Gateway

2022-12-13 Thread yu zelin
Hi, everyone, Looks like our new design is similar to Timo’s suggestion, and considering that there has no response from other devs for a long time, I want to start the vote on Thursday. Best, Yu Zelin > 2022年12月13日 16:23,yu zelin 写道: > > Hi, Timo, > > Thanks for your suggestion.

[jira] [Created] (FLINK-30396) sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block

2022-12-13 Thread Jianhui Dong (Jira)
Jianhui Dong created FLINK-30396: Summary: sql hint 'LOOKUP' which is defined in outer query block may take effect in inner query block Key: FLINK-30396 URL: https://issues.apache.org/jira/browse/FLINK-30396

Re: [DISCUSS] FLIP-275: Support Remote SQL Client Based on SQL Gateway

2022-12-13 Thread yu zelin
Hi, Timo, Thanks for your suggestion. Recently I have discussed with @Godfrey He, @Shengkai Fang and @Jark Wu about the `RowFormat` (Thanks for all your suggestions). We finally came to a consensus which is similar to your suggestion. The details are as follows: 1. Add a REST query parameter

Re: Flink 中的类加载KafkaSerializerWrapper

2022-12-13 Thread Martijn Visser
Hi, Please post to the Dev mailing list in English. Best regards, Martijn On Tue, Dec 13, 2022 at 9:03 AM wangshuai wrote: > >

Flink 中的类加载KafkaSerializerWrapper

2022-12-13 Thread wangshuai
在使用kafka自定义序列化时会导致对应的class无法加载的问题。通过分析,现有代码在使用AppClassLoader类加载器先加载了KafkaSerializerWrapper时,用户提交任务自己编写的类是无法通过AppClassLoader加载的,通过FlinkUserCodeClassLoader加载的话需要KafkaSerializerWrapper也是通过FlinkUserCodeClassLoader加载。 public void open(InitializationContext context) throws Exception { final ClassLoader