[jira] [Created] (FLINK-30424) Add source operator restore readerState log to distinguish split is from newPartitions or split state

Ran Tao created FLINK-30424: --- Summary: Add source operator restore readerState log to distinguish split is from newPartitions or split state Key: FLINK-30424 URL: https://issues.apache.org/jira/browse/FLINK-30424

[jira] [Created] (FLINK-30423) Introduce cast executor codegen for column type evolution

Shammon created FLINK-30423: --- Summary: Introduce cast executor codegen for column type evolution Key: FLINK-30423 URL: https://issues.apache.org/jira/browse/FLINK-30423 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-271: Autoscaling

A heads-up: Gyula just opened a PR with the code contribution based on the design: https://github.com/apache/flink-kubernetes-operator/pull/484 We have run some tests based on the current state and achieved very good results thus far. We were able to cut the resources of some of the deployments

[ANNOUNCE] Apache Flink Kubernetes Operator 1.3.0 released

The Apache Flink community is very happy to announce the release of Apache Flink Kubernetes Operator 1.3.0. Release highlights: - Upgrade to Fabric8 6.x.x and JOSDK 4.x.x - Restart unhealthy Flink clusters - Contribute the Flink Kubernetes Operator to OperatorHub - Publish

[jira] [Created] (FLINK-30422) Generalize token framework provider API

Gabor Somogyi created FLINK-30422: - Summary: Generalize token framework provider API Key: FLINK-30422 URL: https://issues.apache.org/jira/browse/FLINK-30422 Project: Flink Issue Type:

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

Hi All , Thank you for all your valuable suggestions and questions regarding the proposals. In case there are more queries or questions from the community , I will keep this discussion Thread open for a couple of more days and proceed with next steps. Bests Samrat On Wed, Dec 14, 2022 at 9:41

[jira] [Created] (FLINK-30421) Move TGT renewal to hadoop module

Gabor Somogyi created FLINK-30421: - Summary: Move TGT renewal to hadoop module Key: FLINK-30421 URL: https://issues.apache.org/jira/browse/FLINK-30421 Project: Flink Issue Type: Sub-task

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

Thank you Danny for more insights on the flink-connector-aws-base[1]. It looks like localstack supports glue [2], we already use localstack for > integration tests so we can follow suite here. As GlueCatalog will be a part of flink-connector-aws-base. As per suggestion, we will reuse code and

[jira] [Created] (FLINK-30420) NPE thrown when using window time in Table API

Jiang Xin created FLINK-30420: - Summary: NPE thrown when using window time in Table API Key: FLINK-30420 URL: https://issues.apache.org/jira/browse/FLINK-30420 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-30419) Allow tuning of transaction timeout

Vicky Papavasileiou created FLINK-30419: --- Summary: Allow tuning of transaction timeout Key: FLINK-30419 URL: https://issues.apache.org/jira/browse/FLINK-30419 Project: Flink Issue

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

Hi Piotr, Thanks for your valuable input which makes me consider the core point of data consistency in deep. I'd like to define the data consistency on the whole streaming & batch processing as follows and I hope that we can have an agreement on it: BOutput = Fn(BInput), BInput is a bounded

Re: [DISCUSS] FLIP-274 : Introduce metric group for OperatorCoordinator

Hi Hang & MengYue, Thanks for creating this FLIP! I think it is very useful, mainly in two aspects: 1. Enables OperatorCoordinators to register metrics. Currently the coordinators has no way to do this. And operator coordinator metric group further enables the SplitEnumerator to have access to a

Re: Invitation link to Community Slack

Hi Lauri, I've just updated the invite link, so it hopefully should work again. Best regards, Martijn On Wed, Dec 14, 2022 at 2:46 PM Lauri Suurväli wrote: > Hello! > > The invitation link to Flink Community Slack has expired on the website. It > was recommended to write to the dev mailing

Re: I want to join

Hi Ruslan, Check https://flink.apache.org/community.html and https://flink.apache.org/contributing/how-to-contribute.html for all information. Best regards, Martijn On Wed, Dec 14, 2022 at 2:45 PM Ruslan Maznytsia wrote: > >

Re: Slack link expired

Hi Ruben, I've just updated the invite, so it should work again. Can you check? Best regards, Martijn On Wed, Dec 14, 2022 at 2:46 PM Ruben van Vreeland < rubenvanvreel...@gmail.com> wrote: > Hi, > > I would love to join the Slack community, yet the link is expired. > > Could someone renew

Re: Slack Invite

Hi Grant, I've just updated the invite, so it should work again. Can you check? Best regards, Martijn On Wed, Dec 14, 2022 at 2:45 PM Grant Wade wrote: > Hi, > I'd like to join the Flink Slack Community, but the invite link on > https://flink.apache.org/community.html#slack is expired. Can

Invitation link to Community Slack

Hello! The invitation link to Flink Community Slack has expired on the website. It was recommended to write to the dev mailing list in case this had happened. Would anyone be so kind and send me an invitation link? Best regards, Lauri Suurväli -- *** This

Slack link expired

Hi, I would love to join the Slack community, yet the link is expired. Could someone renew the link, or invite me? Looking forward to meeting you there!

Slack Invite

Hi, I'd like to join the Flink Slack Community, but the invite link on https://flink.apache.org/community.html#slack is expired. Can someone please send me an invite link? Thanks, Grant

I want to join

[jira] [Created] (FLINK-30418) Implement synchronous KinesisClient in EFO

Daren Wong created FLINK-30418: -- Summary: Implement synchronous KinesisClient in EFO Key: FLINK-30418 URL: https://issues.apache.org/jira/browse/FLINK-30418 Project: Flink Issue Type:

[VOTE] Release flink-connector-jdbc, release candidate #2

Hi everyone, Please review and vote on the release candidate #2 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-30417) Rabbit error is not clear

Yaron Shani created FLINK-30417: --- Summary: Rabbit error is not clear Key: FLINK-30417 URL: https://issues.apache.org/jira/browse/FLINK-30417 Project: Flink Issue Type: Improvement

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

Hi, all, Thanks for all your feedbacks so far. Through the discussion on this thread[1], I think we have came to a consensus, so I’d like to start a vote on FLIP-275[2]. The vote will last for at least 72 hours (Dec 19th, 13:00 GMT, excluding weekend days) unless there is an objection or

[jira] [Created] (FLINK-30416) Add configureSession REST API in the SQL Gateway

Shengkai Fang created FLINK-30416: - Summary: Add configureSession REST API in the SQL Gateway Key: FLINK-30416 URL: https://issues.apache.org/jira/browse/FLINK-30416 Project: Flink Issue

[jira] [Created] (FLINK-30415) Sync JDBC connector to match with previously released 1.16 version

Martijn Visser created FLINK-30415: -- Summary: Sync JDBC connector to match with previously released 1.16 version Key: FLINK-30415 URL: https://issues.apache.org/jira/browse/FLINK-30415 Project:

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

Hi all, This RC is cancelled due to the missing LICENSE and NOTICE file. I'll work on a fix (including removing the filter pushdown) and create a new RC later. Best regards, Martijn On Mon, Dec 12, 2022 at 9:47 AM Chesnay Schepler wrote: > On 09/12/2022 16:12, Martijn Visser wrote: > > That

[jira] [Created] (FLINK-30414) Add unit test time out when run ci.

Aiden Gong created FLINK-30414: -- Summary: Add unit test time out when run ci. Key: FLINK-30414 URL: https://issues.apache.org/jira/browse/FLINK-30414 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-30413) Drop Share and Key_Shared subscription support in Pulsar connector

Yufan Sheng created FLINK-30413: --- Summary: Drop Share and Key_Shared subscription support in Pulsar connector Key: FLINK-30413 URL: https://issues.apache.org/jira/browse/FLINK-30413 Project: Flink

[jira] [Created] (FLINK-30412) create many checkpoint empty dir when job not enable checkpoint

xiaodao created FLINK-30412: --- Summary: create many checkpoint empty dir when job not enable checkpoint Key: FLINK-30412 URL: https://issues.apache.org/jira/browse/FLINK-30412 Project: Flink Issue

[jira] [Created] (FLINK-30411) Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource

tanjialiang created FLINK-30411: --- Summary: Flink deployment stuck in UPGRADING state when deploy flinkdeployment without resource Key: FLINK-30411 URL: https://issues.apache.org/jira/browse/FLINK-30411

Re: [DISCUSSION] Scan mode in Table Store for Flink Stream and Batch job

Hi all. It seems that we've reached at an agreement. We'll rename "full" scan.mode to "latest-full" and "compacted" scan.mode to "compacted-full". I've created a ticket about this [1] and will work on it soon. [1] https://issues.apache.org/jira/browse/FLINK-30410 Shammon FY 于2022年12月12日周一

[jira] [Created] (FLINK-30410) Rename 'full' to 'latest-full' and 'compacted' to 'compacted-full' for scan.mode in Table Store

Caizhi Weng created FLINK-30410: --- Summary: Rename 'full' to 'latest-full' and 'compacted' to 'compacted-full' for scan.mode in Table Store Key: FLINK-30410 URL: https://issues.apache.org/jira/browse/FLINK-30410