[jira] [Created] (FLINK-29369) Commit delete file failure due to Checkpoint aborted

2022-09-20 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29369: Summary: Commit delete file failure due to Checkpoint aborted Key: FLINK-29369 URL: https://issues.apache.org/jira/browse/FLINK-29369 Project: Flink Issue

[jira] [Created] (FLINK-29368) Modify DESCRIBE statement docs for now syntax

2022-09-20 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-29368: - Summary: Modify DESCRIBE statement docs for now syntax Key: FLINK-29368 URL: https://issues.apache.org/jira/browse/FLINK-29368 Project: Flink Issue Type:

[jira] [Created] (FLINK-29367) Avoid manifest corruption for incorrect checkpoint recovery

2022-09-20 Thread Jingsong Lee (Jira)
Jingsong Lee created FLINK-29367: Summary: Avoid manifest corruption for incorrect checkpoint recovery Key: FLINK-29367 URL: https://issues.apache.org/jira/browse/FLINK-29367 Project: Flink

[jira] [Created] (FLINK-29366) Use flink shaded jacson to parse flink-conf.yaml

2022-09-20 Thread Yuan Kui (Jira)
Yuan Kui created FLINK-29366: Summary: Use flink shaded jacson to parse flink-conf.yaml Key: FLINK-29366 URL: https://issues.apache.org/jira/browse/FLINK-29366 Project: Flink Issue Type:

[jira] [Created] (FLINK-29365) Millisecond behind latest jumps after Flink 1.15.2 upgrade

2022-09-20 Thread Wilson Wu (Jira)
Wilson Wu created FLINK-29365: - Summary: Millisecond behind latest jumps after Flink 1.15.2 upgrade Key: FLINK-29365 URL: https://issues.apache.org/jira/browse/FLINK-29365 Project: Flink Issue

[jira] [Created] (FLINK-29364) Root cause of Exceptions thrown in the SourceReader start() method gets "swallowed".

2022-09-20 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-29364: - Summary: Root cause of Exceptions thrown in the SourceReader start() method gets "swallowed". Key: FLINK-29364 URL: https://issues.apache.org/jira/browse/FLINK-29364

[jira] [Created] (FLINK-29363) Allow web ui to fully redirect to other page

2022-09-20 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-29363: - Summary: Allow web ui to fully redirect to other page Key: FLINK-29363 URL: https://issues.apache.org/jira/browse/FLINK-29363 Project: Flink Issue Type:

[jira] [Created] (FLINK-29362) Allow loading dynamic config for kerberos authentication in CliFrontend

2022-09-20 Thread Biao Geng (Jira)
Biao Geng created FLINK-29362: - Summary: Allow loading dynamic config for kerberos authentication in CliFrontend Key: FLINK-29362 URL: https://issues.apache.org/jira/browse/FLINK-29362 Project: Flink

Re: Kubernetes Operator 1.2.0 release

2022-09-20 Thread Márton Balassi
Thanks, +1 for the schedule. On Tue, Sep 20, 2022 at 6:20 AM Yang Wang wrote: > Thanks Gyula for managing the release. > > +1 for the time schedule. > > > Best, > Yang > > > > Őrhidi Mátyás 于2022年9月19日周一 22:28写道： > > > Thanks Gyula! > > > > Sounds good! Happy to help as always. > > > > Cheers,

[jira] [Created] (FLINK-29361) How to set headers with the new Flink KafkaSink

2022-09-20 Thread Xin Hao (Jira)
Xin Hao created FLINK-29361: --- Summary: How to set headers with the new Flink KafkaSink Key: FLINK-29361 URL: https://issues.apache.org/jira/browse/FLINK-29361 Project: Flink Issue Type:

[SUMMARY] Flink 1.16 release sync of 2022-09-20

2022-09-20 Thread Xingbo Huang
I would like to give you a brief update of the Flink 1.16 release sync meating of 2022-09-20. *We have created release-1.16 rc0 in last Wednesday(14th of September 2022)* *Currently, there are 3 blocker issues which are being worked on. Many thanks to these contributors and reviewers. -

[jira] [Created] (FLINK-29358) Pulsar Table Connector testing

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29358: --- Summary: Pulsar Table Connector testing Key: FLINK-29358 URL: https://issues.apache.org/jira/browse/FLINK-29358 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29359) Pulsar Table Connector pom config and packaging

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29359: --- Summary: Pulsar Table Connector pom config and packaging Key: FLINK-29359 URL: https://issues.apache.org/jira/browse/FLINK-29359 Project: Flink Issue Type:

[jira] [Created] (FLINK-29360) Pulsar Table Connector Documentation

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29360: --- Summary: Pulsar Table Connector Documentation Key: FLINK-29360 URL: https://issues.apache.org/jira/browse/FLINK-29360 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29356) Pulsar Table Source code :implementation

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29356: --- Summary: Pulsar Table Source code :implementation Key: FLINK-29356 URL: https://issues.apache.org/jira/browse/FLINK-29356 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29357) Pulsar Table Sink code: implementation

2022-09-20 Thread Yufei Zhang (Jira)
Yufei Zhang created FLINK-29357: --- Summary: Pulsar Table Sink code: implementation Key: FLINK-29357 URL: https://issues.apache.org/jira/browse/FLINK-29357 Project: Flink Issue Type: Sub-task

Re: [DISCUSS] Externalized connector release details

2022-09-20 Thread Chesnay Schepler
> After 1.16, only patches are accepted for 1.2.0-1.15. I feel like this is a misunderstanding that both you and Danny ran into. What I meant in the original proposal is that the last 2 _major_ /connector /versions are supported, with the latest receiving additional features. (Provided that

[jira] [Created] (FLINK-29355) Sql parse failed because of Desc catalog.database.table is incorrectly parsed to desc catalog

2022-09-20 Thread Yunhong Zheng (Jira)
Yunhong Zheng created FLINK-29355: - Summary: Sql parse failed because of Desc catalog.database.table is incorrectly parsed to desc catalog Key: FLINK-29355 URL: https://issues.apache.org/jira/browse/FLINK-29355

Re: [DISCUSS] Externalized connector release details

2022-09-20 Thread Jing Ge
Hi, Thanks for starting this discussion. It is an interesting one and yeah, it is a tough topic. It seems like a centralized release version schema control for decentralized connector development ;-) In general, I like this idea, not because it is a good one but because there might be no better

[jira] [Created] (FLINK-29354) Support TO_DATE and TO_TIMESTAMP built-in function in the Table API

2022-09-20 Thread Luning Wang (Jira)
Luning Wang created FLINK-29354: --- Summary: Support TO_DATE and TO_TIMESTAMP built-in function in the Table API Key: FLINK-29354 URL: https://issues.apache.org/jira/browse/FLINK-29354 Project: Flink

[jira] [Created] (FLINK-29353) Support UNIX_TIMESTAMP built-in function in Table API

2022-09-20 Thread Luning Wang (Jira)
Luning Wang created FLINK-29353: --- Summary: Support UNIX_TIMESTAMP built-in function in Table API Key: FLINK-29353 URL: https://issues.apache.org/jira/browse/FLINK-29353 Project: Flink Issue

[jira] [Created] (FLINK-29352) Support CONVERT_TZ built-in function in Table API

2022-09-20 Thread Luning Wang (Jira)
Luning Wang created FLINK-29352: --- Summary: Support CONVERT_TZ built-in function in Table API Key: FLINK-29352 URL: https://issues.apache.org/jira/browse/FLINK-29352 Project: Flink Issue Type:

[jira] [Created] (FLINK-29351) Enable input buffer floating for blocking shuffle

2022-09-20 Thread Yingjie Cao (Jira)
Yingjie Cao created FLINK-29351: --- Summary: Enable input buffer floating for blocking shuffle Key: FLINK-29351 URL: https://issues.apache.org/jira/browse/FLINK-29351 Project: Flink Issue Type:

Re: [DISCUSS] FLIP-260: Expose Finish Method For UserDefinedFunction

2022-09-20 Thread Piotr Nowojski
Fine by me. Thanks for driving this Lincoln :) Best, Piotrek wt., 20 wrz 2022 o 09:06 Lincoln Lee napisał(a): > Hi all, >I'll start a vote if there are no more objections till this > thursday(9.22). Looking forward to your feedback! > > [1] Flip-260: > >

Re: [DISCUSS] Externalized connector release details

2022-09-20 Thread Martijn Visser
Hi all, This is a tough topic, I also had to write things down a couple of times. To summarize and add my thoughts: a) I think everyone is agreeing that "Only the last 2 versions of a connector are supported per supported Flink version, with only the latest version receiving new features". In

Re: [DISCUSS] Externalized connector release details

2022-09-20 Thread Chesnay Schepler
c) @Ryan: I'm generally fine with leaving it up to the connector on how to implement Flink version-specific behavior, so long as the branching models stays consistent (primarily so that the release process is identical and we can share infrastructure). @Danny: In a single branch per version

[jira] [Created] (FLINK-29350) Add a note for swapping planner jar in Hive dependencies page

2022-09-20 Thread luoyuxia (Jira)
luoyuxia created FLINK-29350: Summary: Add a note for swapping planner jar in Hive dependencies page Key: FLINK-29350 URL: https://issues.apache.org/jira/browse/FLINK-29350 Project: Flink Issue

[jira] [Created] (FLINK-29349) Use state ttl instead of timer to clean up state in proctime over aggregate

2022-09-20 Thread lincoln lee (Jira)
lincoln lee created FLINK-29349: --- Summary: Use state ttl instead of timer to clean up state in proctime over aggregate Key: FLINK-29349 URL: https://issues.apache.org/jira/browse/FLINK-29349 Project:

[jira] [Created] (FLINK-29348) The DPP(dynamic partition pruning) can not work with adaptive batch scheduler

2022-09-20 Thread Lijie Wang (Jira)
Lijie Wang created FLINK-29348: -- Summary: The DPP(dynamic partition pruning) can not work with adaptive batch scheduler Key: FLINK-29348 URL: https://issues.apache.org/jira/browse/FLINK-29348 Project:

Re: [DISCUSS] FLIP-260: Expose Finish Method For UserDefinedFunction

2022-09-20 Thread Lincoln Lee
Hi all, I'll start a vote if there are no more objections till this thursday(9.22). Looking forward to your feedback! [1] Flip-260: https://cwiki.apache.org/confluence/display/FLINK/FLIP-260%3A+Expose+Finish+Method+For+TableFunction [2] PoC:

[jira] [Created] (FLINK-29347) Failed to restore from list state with empty protobuf object

2022-09-20 Thread shen (Jira)
shen created FLINK-29347: Summary: Failed to restore from list state with empty protobuf object Key: FLINK-29347 URL: https://issues.apache.org/jira/browse/FLINK-29347 Project: Flink Issue Type: