[jira] [Created] (FLINK-25370) HBase SQL Connector Options 'table-name' description

Ibson created FLINK-25370: - Summary: HBase SQL Connector Options 'table-name' description Key: FLINK-25370 URL: https://issues.apache.org/jira/browse/FLINK-25370 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-25369) CatalogManager provide wrong tables or views in given catalog database name

Yubin Li created FLINK-25369: Summary: CatalogManager provide wrong tables or views in given catalog database name Key: FLINK-25369 URL: https://issues.apache.org/jira/browse/FLINK-25369 Project: Flink

[jira] [Created] (FLINK-25368) Use AdminClient to get offsets rather than KafkaConsumer

dengziming created FLINK-25368: -- Summary: Use AdminClient to get offsets rather than KafkaConsumer Key: FLINK-25368 URL: https://issues.apache.org/jira/browse/FLINK-25368 Project: Flink Issue Ty

Re: [DISCUSS] JUnit 5 Migration

Thanks Hang and Qingsheng for your effort and starting this discussion. As additional information, I've created an umbrella ticket( https://issues.apache.org/jira/browse/FLINK-25325). It is recommended to create all JUnit5 migration related tasks under it, So we could track the whole migration easi

[jira] [Created] (FLINK-25367) Upgrade Flink dependency to 1.13.5

Igal Shilman created FLINK-25367: Summary: Upgrade Flink dependency to 1.13.5 Key: FLINK-25367 URL: https://issues.apache.org/jira/browse/FLINK-25367 Project: Flink Issue Type: Improvement

Re: [DISCUSS] Releasing Flink ML 2.0.0

Hi Dong, Thanks for starting the discussion. It is really a great pleasure to be part of the FlinkML project. Cheers :) Dong Lin 于2021年12月17日周五 22:22写道： > Hi devs, > > Yun and I would like to start a discussion for releasing Flink ML > 2.0.0 > > In the past

[DISCUSS] Releasing Flink ML 2.0.0

Hi devs, Yun and I would like to start a discussion for releasing Flink ML 2.0.0 In the past few months, we have made a substantial amount of improvements in Flink ML. These improvements include FLIP-173

[jira] [Created] (FLINK-25366) Enforce BINARY/VARBINARY precision when outputing to a Sink

Marios Trivyzas created FLINK-25366: --- Summary: Enforce BINARY/VARBINARY precision when outputing to a Sink Key: FLINK-25366 URL: https://issues.apache.org/jira/browse/FLINK-25366 Project: Flink

[DISCUSS] JUnit 5 Migration

Hi, all, Apache Flink is using JUnit for unit tests and integration tests widely in the project, however, it binds to the legacy JUnit 4 deeply. It is important to migrate existing cases to JUnit 5 in order to avoid splitting the project into different JUnit versions. Qingsheng Ren and I have con

[jira] [Created] (FLINK-25365) Remove remaining references to planner from Python

Timo Walther created FLINK-25365: Summary: Remove remaining references to planner from Python Key: FLINK-25365 URL: https://issues.apache.org/jira/browse/FLINK-25365 Project: Flink Issue Type

[jira] [Created] (FLINK-25364) Don't generate code in open() methods of Python operators

Timo Walther created FLINK-25364: Summary: Don't generate code in open() methods of Python operators Key: FLINK-25364 URL: https://issues.apache.org/jira/browse/FLINK-25364 Project: Flink Iss

[jira] [Created] (FLINK-25363) Replace LogicalWindow and related planner expressions

Timo Walther created FLINK-25363: Summary: Replace LogicalWindow and related planner expressions Key: FLINK-25363 URL: https://issues.apache.org/jira/browse/FLINK-25363 Project: Flink Issue T

Re: [DISCUSS] FLIP-200: Support Multiple Rule and Dynamic Rule Changing (Flink CEP)

Glad to see the Community's progress in Flink CEP. After reading this Flip, I have few questions, would you please take a look ? 1. About Pattern Updating. If we use PatternProcessoerDiscoverer to update the rules, will it increase the load of JM? For example, if the user wants the updated rule t

[jira] [Created] (FLINK-25362) Incorrect dependencies in Table Confluent/Avro docs

Nico Kruber created FLINK-25362: --- Summary: Incorrect dependencies in Table Confluent/Avro docs Key: FLINK-25362 URL: https://issues.apache.org/jira/browse/FLINK-25362 Project: Flink Issue Type:

Re: [ANNOUNCE] Apache Flink 1.14.2 / 1.13.5 / 1.12.7 / 1.11.6 released

Please see the blogpost. On 17/12/2021 06:59, casel.chen wrote: I can NOT find flink 1.13.5 related jar in maven central repository, did you upload them onto there already? Thanks! At 2021-12-17 01:26:19, "Chesnay Schepler" wrote: >The Apache Flink community has released emergency bugf

Re: [ANNOUNCE] Apache Flink 1.14.2 / 1.13.5 / 1.12.7 / 1.11.6 released

We are aware of that; it was also mentioned in the blogpost. On 17/12/2021 07:17, wenlong.lwl wrote: Hi, @Chesnay Schepler I want to forward a feedback from the user mailing list, the jars of the new patch releases are not available at the central maven repo. example: https://mvnrepository.com

Re:[ANNOUNCE] Apache Flink 1.14.2 / 1.13.5 / 1.12.7 / 1.11.6 released

I can NOT find flink 1.13.5 related jar in maven central repository, did you upload them onto there already? Thanks! At 2021-12-17 01:26:19, "Chesnay Schepler" wrote: >The Apache Flink community has released emergency bugfix versions of >Apache Flink for the 1.11, 1.12, 1.13 and

[jira] [Created] (FLINK-25361) Support bounded timestamp in kafka table connector

ZhuoYu Chen created FLINK-25361: --- Summary: Support bounded timestamp in kafka table connector Key: FLINK-25361 URL: https://issues.apache.org/jira/browse/FLINK-25361 Project: Flink Issue Type:

Re: [ANNOUNCE] Apache Flink 1.14.2 / 1.13.5 / 1.12.7 / 1.11.6 released

Thanks a lot for driving these releases Chesnay! This is super helpful for the community. For the synchronization problem, I guess we just have to wait a bit longer. Cheers, Till On Fri, Dec 17, 2021 at 7:39 AM Leonard Xu wrote: > I guess this is related to publishers everywhere are updating t

Re: [DISCUSS] Immediate dedicated StateFun releases for log4j vulnerability

+1, Cheers, Till On Thu, Dec 16, 2021 at 8:15 PM Chesnay Schepler wrote: > +1 > > On 16/12/2021 19:30, Igal Shilman wrote: > > Hi All, > > > > Following the recent Apache Flink releases due to the log4j > vulnerability, > > I'd like to propose an immediate StateFun release - 3.1.1. > > This rel

[jira] [Created] (FLINK-25360) Add State Desc to CheckpointMetadata

刘方奇 created FLINK-25360: --- Summary: Add State Desc to CheckpointMetadata Key: FLINK-25360 URL: https://issues.apache.org/jira/browse/FLINK-25360 Project: Flink Issue Type: Improvement Componen