[jira] [Created] (FLINK-34207) org.apache.flink:flink-shaded-jackson:jar:2.15.3-18.0 couldn't be downloaded

Matthias Pohl created FLINK-34207: - Summary: org.apache.flink:flink-shaded-jackson:jar:2.15.3-18.0 couldn't be downloaded Key: FLINK-34207 URL: https://issues.apache.org/jira/browse/FLINK-34207 Projec

[jira] [Created] (FLINK-34206) CacheITCase.testRetryOnCorruptedClusterDataset(Path) failed

Matthias Pohl created FLINK-34206: - Summary: CacheITCase.testRetryOnCorruptedClusterDataset(Path) failed Key: FLINK-34206 URL: https://issues.apache.org/jira/browse/FLINK-34206 Project: Flink

RE: [DISCUSS] One sql syntax mistake in flip204

Sorry, in the sql is not correct. So the origin SQL in flip-204 is SELECT /*+ SHUFFLE_HASH('Customers') */ o.order_id, o.total, c.country, c.zip FROM Orders AS o JOIN Customers FOR SYSTEM_TIME AS OF o.proc_time AS c ON o.customer_id = c.id; The correct syntax is: SELECT /*+ SHUF

[DISCUSS] One sql syntax mistake in flip204

Hi dev, I am working on advancing the flip204 project, but I have noticed an error in the SQL syntax section. The sql syntax in the documentation is: SELECT /*+ SHUFFLE_HASH('Customers') */ o.order_id, o.total, c.country, c.zip FROM Orders AS o JOIN Customers FOR SYSTEM_TIME AS OF o.proc_time

[jira] [Created] (FLINK-34205) Update flink-docker's Dockerfile and docker-entrypoint.sh to use BashJavaUtils for Flink configuration management

Junrui Li created FLINK-34205: - Summary: Update flink-docker's Dockerfile and docker-entrypoint.sh to use BashJavaUtils for Flink configuration management Key: FLINK-34205 URL: https://issues.apache.org/jira/browse/FL

[jira] [Created] (FLINK-34204) Dispatch legacy serializer related methods in ExecutionConfig to SerializerConfig

Weijie Guo created FLINK-34204: -- Summary: Dispatch legacy serializer related methods in ExecutionConfig to SerializerConfig Key: FLINK-34204 URL: https://issues.apache.org/jira/browse/FLINK-34204 Project

Confluence access

Hi devs! I want to suggest a flip, but I couldn't find the Confluence registration portal. - Can you help me create an account and add editing permission？

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

Thanks Martijn for the feedback! Sounds make sense to me! And I don't have strong opinion that allow backporting new features to 1.x. Best, Rui On Mon, Jan 22, 2024 at 8:56 PM Martijn Visser wrote: > Hi Rui, > > I don't think that we should allow backporting of new features from > the first mi

Re: DataOutputSerializer serializing long UTF Strings

I think this is a reasonable extension to `DataOutputSerializer`. Although 64 KB is not small, it is still possible to have long strings over that limit. There are already precedents of extended APIs `DataOutputSerializer`. E.g. public void setPosition(int position) { Preconditions.checkArgume

[jira] [Created] (FLINK-34203) PyFlink `get_field_data_types()` supports only `precision = 3` for `TimestampType`

Mehmet Aktas created FLINK-34203: Summary: PyFlink `get_field_data_types()` supports only `precision = 3` for `TimestampType` Key: FLINK-34203 URL: https://issues.apache.org/jira/browse/FLINK-34203 Pr

Re: [DISCUSS] FLIP-402: Extend ZooKeeper Curator configurations

Hello Matthias, Thanks a lot for the feedback. - Regarding names: sure it totally makes sense to follow the kebab case and Flip has reflected the change. Regarding the convention, Flink has this widely used configuration storageDir, which doesn't follow the kebab rule and creates some confusion.

[jira] [Created] (FLINK-34202) python tests take suspiciously long in some of the cases

Matthias Pohl created FLINK-34202: - Summary: python tests take suspiciously long in some of the cases Key: FLINK-34202 URL: https://issues.apache.org/jira/browse/FLINK-34202 Project: Flink Is

[jira] [Created] (FLINK-34201) Datadog name resolution fails and do not retry causing metrics to not get exported

Pedro Mázala created FLINK-34201: Summary: Datadog name resolution fails and do not retry causing metrics to not get exported Key: FLINK-34201 URL: https://issues.apache.org/jira/browse/FLINK-34201 Pr

[jira] [Created] (FLINK-34200) AutoRescalingITCase#testCheckpointRescalingInKeyedState fails

Matthias Pohl created FLINK-34200: - Summary: AutoRescalingITCase#testCheckpointRescalingInKeyedState fails Key: FLINK-34200 URL: https://issues.apache.org/jira/browse/FLINK-34200 Project: Flink

[jira] [Created] (FLINK-34199) Add tracing for durations of rescaling/restoring from local state

Stefan Richter created FLINK-34199: -- Summary: Add tracing for durations of rescaling/restoring from local state Key: FLINK-34199 URL: https://issues.apache.org/jira/browse/FLINK-34199 Project: Flink

[jira] [Created] (FLINK-34198) Remove e2e test operator log error check

Gabor Somogyi created FLINK-34198: - Summary: Remove e2e test operator log error check Key: FLINK-34198 URL: https://issues.apache.org/jira/browse/FLINK-34198 Project: Flink Issue Type: Improv

Re: [DISCUSS] Proposing an LTS Release for the 1.x Line

Hi Rui, I don't think that we should allow backporting of new features from the first minor version of 2.x to 1.x. If a user doesn't yet want to upgrade to 2.0, I think that's fine since we'll have a LTS for 1.x. If a newer feature becomes available in 2.x that's interesting for the user, the user

Re: Confluence access

Hi, What's your Confluence user name? Best regards, Martijn On Fri, Jan 19, 2024 at 8:04 AM Сергей Парышев wrote: > > > Hi devs! Can I get access to confluence? I want suggest a FLIP.

[jira] [Created] (FLINK-34197) How can i recover job by savepoint with multi-job run by executeAsync in application mode

mazhenzz created FLINK-34197: Summary: How can i recover job by savepoint with multi-job run by executeAsync in application mode Key: FLINK-34197 URL: https://issues.apache.org/jira/browse/FLINK-34197 Pro

Re: [DISCUSS] FLIP-402: Extend ZooKeeper Curator configurations

Hi Alex, thanks for bringing this up and sorry for jumping into the discussion that late. Exposing additional curator configuration parameters through Flink's config sounds reasonable. Overall, I am fine with the selection of parameters. My judgement is entirely based on the curator description, th

[jira] [Created] (FLINK-34196) FLIP-389 Annotate SingleThreadFetcherManager as PublicEvolving.

Hongshun Wang created FLINK-34196: - Summary: FLIP-389 Annotate SingleThreadFetcherManager as PublicEvolving. Key: FLINK-34196 URL: https://issues.apache.org/jira/browse/FLINK-34196 Project: Flink

[RESULT][VOTE] FLIP-389 Annotate SingleThreadFetcherManager as PublicEvolving.

Hi devs, I'm glad to announce that the FLIP-389[1] has been accepted. The voting thread is here[2]. The proposal received 4 approving votes, three of which are binding: - Leonard Xu (binding) - Qingsheng Ren (binding) - Xuyang (non-binding) - Ron liu (binding) And there is no disapproving

Re: [ANNOUNCE] Apache Flink 1.18.1 released

Hi folks, I am still working on the official images because of the issue https://issues.apache.org/jira/browse/FLINK-34165. Images under apache/flink are available. Best regards, Jing On Sun, Jan 21, 2024 at 11:06 PM Jing Ge wrote: > Thanks Leonard for the feedback! Also thanks @Jark Wu > @C

Re: [DISCUSS] FLIP-406: Reorganize State & Checkpointing & Recovery Configuration

Hi everyone, It has been 6 days since the last call for discussion. I'd like to start a vote after another 2 days. Please let me know if you have any concerns. Thanks! Best, Zakelly On Tue, Jan 16, 2024 at 2:54 PM Zakelly Lan wrote: > Thanks for the suggestion Rui! The type is added. > > >

[jira] [Created] (FLINK-34195) PythonEnvUtils creates python environment instead of python3

Matthias Pohl created FLINK-34195: - Summary: PythonEnvUtils creates python environment instead of python3 Key: FLINK-34195 URL: https://issues.apache.org/jira/browse/FLINK-34195 Project: Flink

[jira] [Created] (FLINK-34194) Upgrade Flink CI Docker container to Ubuntu 22.04

Matthias Pohl created FLINK-34194: - Summary: Upgrade Flink CI Docker container to Ubuntu 22.04 Key: FLINK-34194 URL: https://issues.apache.org/jira/browse/FLINK-34194 Project: Flink Issue Typ

[jira] [Created] (FLINK-34193) Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka

Martijn Visser created FLINK-34193: -- Summary: Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka Key: FLINK-34193 URL: https://issues.apache.org/jira/browse/FLINK-34193 Proje

[jira] [Created] (FLINK-34192) Update flink-connector-kafka to be compatible with updated SinkV2 interfaces

Martijn Visser created FLINK-34192: -- Summary: Update flink-connector-kafka to be compatible with updated SinkV2 interfaces Key: FLINK-34192 URL: https://issues.apache.org/jira/browse/FLINK-34192 Proj