[jira] [Created] (FLINK-36780) Kafka source disable partition discovery unexpectedly

Mingliang Liu created FLINK-36780: - Summary: Kafka source disable partition discovery unexpectedly Key: FLINK-36780 URL: https://issues.apache.org/jira/browse/FLINK-36780 Project: Flink

[jira] [Created] (FLINK-36679) Add a metric to track checkpoint _metadata size

Mingliang Liu created FLINK-36679: - Summary: Add a metric to track checkpoint _metadata size Key: FLINK-36679 URL: https://issues.apache.org/jira/browse/FLINK-36679 Project: Flink Issue Type

[jira] [Created] (FLINK-36604) StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh

Mingliang Liu created FLINK-36604: - Summary: StreamingJobGraphGenerator::setOperatorConfig checks input serializer lengh Key: FLINK-36604 URL: https://issues.apache.org/jira/browse/FLINK-36604

Re: [VOTE] FLIP-466: Introduce ProcessFunction Attribute in DataStream API V2

+1 (non-binding) on this. Loving these hint-based attributes to gain "managed" optimizations. On Mon, Jul 22, 2024 at 6:15 AM Li Wang wrote: > +1 (non-binding) from me as well. This would help in multiple use-cases. > > Thanks > > On Mon, Jul 22, 2024 at 11:47 AM Rui Fan <1996fan...@gmail.com> w

Re: [Discuss] Non-retriable (partial) errors in Elasticsearch 8 connector

xceptionClassifier.java > 2- > > https://github.com/apache/flink-connector-aws/blob/c688a8545ac1001c8450e8c9c5fe8bbafa13aeba/flink-connector-aws/flink-connector-dynamodb/src/main/java/org/apache/flink/connector/dynamodb/sink/DynamoDbSinkWriter.java#L227 > > 3-https://issues.apache

[jira] [Created] (FLINK-35546) Elasticsearch 8 connector fails fast for non-retryable bulk request items

Mingliang Liu created FLINK-35546: - Summary: Elasticsearch 8 connector fails fast for non-retryable bulk request items Key: FLINK-35546 URL: https://issues.apache.org/jira/browse/FLINK-35546 Project

Re: [ANNOUNCE] New Apache Flink PMC Member - Weijie Guo

Congratulations! (and thanks for reviewing multiple of my PRs!) On Wed, Jun 5, 2024 at 7:26 PM Samrat Deb wrote: > Congratulations > > Bests, > Samrat > > On Thu, 6 Jun 2024 at 7:28 AM, Xuannan Su wrote: > > > Congratulations! > > > > Best regards, > > Xuannan > > > > On Thu, Jun 6, 2024 at 9:

[Discuss] Non-retriable (partial) errors in Elasticsearch 8 connector

Hi all, Currently the Elasticsearch 8 connector retries all items if the request fails as a whole, and retries failed items if the request has partial failures [1]. I think this infinitely retries might be problematic in some cases when retrying can never eventually succeed. For example, if the re

[jira] [Created] (FLINK-35504) Improve Elasticsearch 8 connector observability

Mingliang Liu created FLINK-35504: - Summary: Improve Elasticsearch 8 connector observability Key: FLINK-35504 URL: https://issues.apache.org/jira/browse/FLINK-35504 Project: Flink Issue Type

[jira] [Created] (FLINK-35472) Improve tests for Elasticsearch 8 connector

Mingliang Liu created FLINK-35472: - Summary: Improve tests for Elasticsearch 8 connector Key: FLINK-35472 URL: https://issues.apache.org/jira/browse/FLINK-35472 Project: Flink Issue Type

[jira] [Created] (FLINK-35424) Elasticsearch connector 8 supports SSL context

Mingliang Liu created FLINK-35424: - Summary: Elasticsearch connector 8 supports SSL context Key: FLINK-35424 URL: https://issues.apache.org/jira/browse/FLINK-35424 Project: Flink Issue Type

[jira] [Created] (FLINK-35287) Builder builds NetworkConfig for Elasticsearch connector 8

Mingliang Liu created FLINK-35287: - Summary: Builder builds NetworkConfig for Elasticsearch connector 8 Key: FLINK-35287 URL: https://issues.apache.org/jira/browse/FLINK-35287 Project: Flink

[jira] [Created] (FLINK-35148) Improve InstantiationUtil for checking nullary public constructor

Mingliang Liu created FLINK-35148: - Summary: Improve InstantiationUtil for checking nullary public constructor Key: FLINK-35148 URL: https://issues.apache.org/jira/browse/FLINK-35148 Project: Flink

[jira] [Created] (FLINK-34632) Log checkpoint Id when logging checkpoint processing delay

Mingliang Liu created FLINK-34632: - Summary: Log checkpoint Id when logging checkpoint processing delay Key: FLINK-34632 URL: https://issues.apache.org/jira/browse/FLINK-34632 Project: Flink

[jira] [Created] (FLINK-34369) Elasticsearch connector supports SSL provider

Mingliang Liu created FLINK-34369: - Summary: Elasticsearch connector supports SSL provider Key: FLINK-34369 URL: https://issues.apache.org/jira/browse/FLINK-34369 Project: Flink Issue Type

[jira] [Created] (FLINK-34251) ClosureCleaner to include reference classes for non-serialization exception

Mingliang Liu created FLINK-34251: - Summary: ClosureCleaner to include reference classes for non-serialization exception Key: FLINK-34251 URL: https://issues.apache.org/jira/browse/FLINK-34251

Re: [DISCUSS] FLIP-364: Improve the restart-strategy

? >> >> Thanks Zhu mentioned the concurrentExceptions, and thanks Matthias >> help double check. >> >> [1] https://issues.apache.org/jira/browse/FLINK-33565 >> >> Best, >> Rui >> >> On Thu, Nov 16, 2023 at 11:39 AM Rui Fan <1996fan...@gmail.c

Re: [VOTE] FLIP-378: Support Avro timestamp with local timezone

+1 (non-binding) On Wed, Nov 15, 2023 at 3:38 PM Peter Huang wrote: > Hi Devs, > > I'd like to start a vote on FLIP-378: Support Avro timestamp with local > timezone which has been discussed in this thread [2]. > > The vote will be open for at least 72 hours unless there is an objection or > not

Re: [DISCUSS] FLIP-364: Improve the restart-strategy

difying the default value. > If this is very difficult to reach consensus on, I can remove > this item from FLIP. > > Best, > Rui > > On Wed, Nov 15, 2023 at 6:40 AM Mingliang Liu wrote: > >> Thanks Rui for driving this. I just call out that making exponential-delay

Re: [DISCUSS] FLIP-364: Improve the restart-strategy

Thanks Rui for driving this. I just call out that making exponential-delay the default is a good change. At Netflix, we have enabled this as the default restart strategy 2 quarters ago and it has been working well. Keeping it restarting indefinitely by default makes sense to me. On Mon, Oct 16, 20

Re: [DISCUSS] FLIP-378: Support Avro timestamp with local timezone

+1 on this effort. I opened a JIRA sometime ago on this topic [1] and Jagadesh submitted a PR [2] for review. In the comments, James proposed a different approach from the PR. I don't think this topic was well-discussed there by the community and no consensus on how to move forward. Reading the do

Re: [VOTE] FLIP-381: Deprecate configuration getters/setters that return/set complex Java objects

+1 (non-binding) Thanks for driving this. On Mon, Nov 13, 2023 at 12:37 AM Hang Ruan wrote: > +1(non-binding) > > Best, > Hang > > Jing Ge 于2023年11月13日周一 16:36写道： > > > +1(binding) > > Thanks! > > > > Best Regards, > > Jing > > > > On Mon, Nov 13, 2023 at 8:34 AM Zhu Zhu wrote: > > > > > +1 (

[jira] [Created] (FLINK-31984) Savepoint on S3 should be relocatable if entropy injection is not effective

Mingliang Liu created FLINK-31984: - Summary: Savepoint on S3 should be relocatable if entropy injection is not effective Key: FLINK-31984 URL: https://issues.apache.org/jira/browse/FLINK-31984

[jira] [Created] (FLINK-31110) Web UI shows "User Configuration" preserving lines and whitespaces

Mingliang Liu created FLINK-31110: - Summary: Web UI shows "User Configuration" preserving lines and whitespaces Key: FLINK-31110 URL: https://issues.apache.org/jira/browse/FLINK-31110 Proj

[jira] [Created] (FLINK-30483) Make Avro format support for TIMESTAMP_LTZ

Mingliang Liu created FLINK-30483: - Summary: Make Avro format support for TIMESTAMP_LTZ Key: FLINK-30483 URL: https://issues.apache.org/jira/browse/FLINK-30483 Project: Flink Issue Type

[jira] [Created] (FLINK-30479) Document flink-connector-files for local execution

Mingliang Liu created FLINK-30479: - Summary: Document flink-connector-files for local execution Key: FLINK-30479 URL: https://issues.apache.org/jira/browse/FLINK-30479 Project: Flink Issue

[Discuss] SQL Client syntax to show a configuration

Hi all, Currently in SQL Client we can use the "SET 'key'='value'" command to set a value to a config property key for the session. We can also list all config properties by just calling "SET". It would be convenient to show the value of a specific config property given its key(s). Without this, u

[jira] [Created] (FLINK-30459) SQL Client supports "SET 'property'"

Mingliang Liu created FLINK-30459: - Summary: SQL Client supports "SET 'property'" Key: FLINK-30459 URL: https://issues.apache.org/jira/browse/FLINK-30459 Project: Flink

[jira] [Created] (FLINK-30179) Stop stringifying exception for logging

Mingliang Liu created FLINK-30179: - Summary: Stop stringifying exception for logging Key: FLINK-30179 URL: https://issues.apache.org/jira/browse/FLINK-30179 Project: Flink Issue Type

[jira] [Created] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

Mingliang Liu created FLINK-30081: - Summary: Local executor can not accept different jvm-overhead.min/max values Key: FLINK-30081 URL: https://issues.apache.org/jira/browse/FLINK-30081 Project: Flink

[jira] [Created] (FLINK-30079) Stop using deprecated TM options in doc

Mingliang Liu created FLINK-30079: - Summary: Stop using deprecated TM options in doc Key: FLINK-30079 URL: https://issues.apache.org/jira/browse/FLINK-30079 Project: Flink Issue Type

[jira] [Created] (FLINK-29961) Make referencing custom image clearer for Docker

Mingliang Liu created FLINK-29961: - Summary: Make referencing custom image clearer for Docker Key: FLINK-29961 URL: https://issues.apache.org/jira/browse/FLINK-29961 Project: Flink Issue

[jira] [Created] (FLINK-29940) ExecutionGraph logs job state change at ERROR level when job fails

Mingliang Liu created FLINK-29940: - Summary: ExecutionGraph logs job state change at ERROR level when job fails Key: FLINK-29940 URL: https://issues.apache.org/jira/browse/FLINK-29940 Project: Flink

[jira] [Created] (FLINK-29920) Minor reformat Kafka connector documentation

Mingliang Liu created FLINK-29920: - Summary: Minor reformat Kafka connector documentation Key: FLINK-29920 URL: https://issues.apache.org/jira/browse/FLINK-29920 Project: Flink Issue Type

[jira] [Created] (FLINK-29750) Improve PostgresCatalog#listTables() by reusing resources

Mingliang Liu created FLINK-29750: - Summary: Improve PostgresCatalog#listTables() by reusing resources Key: FLINK-29750 URL: https://issues.apache.org/jira/browse/FLINK-29750 Project: Flink

[jira] [Created] (FLINK-27278) Fix wrong indentation in doc dev/datastream/operators/windows.md

Mingliang Liu created FLINK-27278: - Summary: Fix wrong indentation in doc dev/datastream/operators/windows.md Key: FLINK-27278 URL: https://issues.apache.org/jira/browse/FLINK-27278 Project: Flink

Re: [DISCUSS] JUnit 5 Migration

>Some modules are already migrated by us, but the code hasn't been merged since we still have some pending details to discuss. I see you have created sub-task JIRAs for those modules in the umbrella JIRA FLINK-25325 . But they are still unassigned