[VOTE] FLIP-416: Deprecate and remove the RestoreMode#LEGACY

2024-01-18 Thread Zakelly Lan
Hi everyone, I'd like to start a vote on the FLIP-416: Deprecate and remove the RestoreMode#LEGACY [1]. The discussion thread is here [2]. The vote will be open for at least 72 hours unless there is an objection or insufficient votes. [1] https://cwiki.apache.org/confluence/x/ookkEQ [2]

Re:Re: [VOTE] FLIP-415: Introduce a new join operator to support minibatch

2024-01-18 Thread Xuyang
+1 (non-binding)-- Best! Xuyang 在 2024-01-19 13:28:52,"Lincoln Lee" 写道: >+1 (binding) > >Best, >Lincoln Lee > > >Benchao Li 于2024年1月19日周五 13:15写道: > >> +1 (binding) >> >> shuai xu 于2024年1月19日周五 12:58写道: >> >>> Dear Flink Developers, >>> >>> Thank you for providing feedback on

[jira] [Created] (FLINK-34165) It seems that Apache download link has been changed

2024-01-18 Thread Jing Ge (Jira)
Jing Ge created FLINK-34165: --- Summary: It seems that Apache download link has been changed Key: FLINK-34165 URL: https://issues.apache.org/jira/browse/FLINK-34165 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34168) Refactor all callers that using the public Xxx getXxx(String key) and public void setXxx(String key, Xxx value)

2024-01-18 Thread Rui Fan (Jira)
Rui Fan created FLINK-34168: --- Summary: Refactor all callers that using the public Xxx getXxx(String key) and public void setXxx(String key, Xxx value) Key: FLINK-34168 URL:

Re: [VOTE] FLIP-416: Deprecate and remove the RestoreMode#LEGACY

2024-01-18 Thread Yanfei Lei
+1 (binding) Best, Yanfei Hangxiang Yu 于2024年1月19日周五 12:13写道: > > +1 (binding) > > On Fri, Jan 19, 2024 at 12:10 PM Zakelly Lan wrote: > > > Hi everyone, > > > > I'd like to start a vote on the FLIP-416: Deprecate and remove the > > RestoreMode#LEGACY [1]. The discussion thread is here [2]. >

Re: [VOTE] FLIP-415: Introduce a new join operator to support minibatch

2024-01-18 Thread Benchao Li
+1 (binding) shuai xu 于2024年1月19日周五 12:58写道: > Dear Flink Developers, > > Thank you for providing feedback on FLIP-415: Introduce a new join > operator to support minibatch[1]. I'd like to start a vote on this FLIP. > Here is the discussion thread[2]. > > After the discussion, this FLIP will

Re: [VOTE] FLIP-415: Introduce a new join operator to support minibatch

2024-01-18 Thread Lincoln Lee
+1 (binding) Best, Lincoln Lee Benchao Li 于2024年1月19日周五 13:15写道: > +1 (binding) > > shuai xu 于2024年1月19日周五 12:58写道: > >> Dear Flink Developers, >> >> Thank you for providing feedback on FLIP-415: Introduce a new join >> operator to support minibatch[1]. I'd like to start a vote on this FLIP.

Re:Re: [VOTE] FLIP-389: Annotate SingleThreadFetcherManager as PublicEvolving

2024-01-18 Thread Xuyang
+1 (non-binding) -- Best! Xuyang 在 2024-01-19 10:16:23,"Qingsheng Ren" 写道: >+1 (binding) > >Thanks for the work, Hongshun! > >Best, >Qingsheng > >On Tue, Jan 16, 2024 at 11:21 AM Leonard Xu wrote: > >> Thanks Hongshun for driving this ! >> >> +1(binding) >> >> Best, >> Leonard >>

退订

2024-01-18 Thread dev
退订

[jira] [Created] (FLINK-34164) [Benchmark] Compilation error since Jan. 16th

2024-01-18 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34164: --- Summary: [Benchmark] Compilation error since Jan. 16th Key: FLINK-34164 URL: https://issues.apache.org/jira/browse/FLINK-34164 Project: Flink Issue Type: Bug

Re: Re: [VOTE] FLIP-415: Introduce a new join operator to support minibatch

2024-01-18 Thread liu ron
+1(binding) Best, Ron Xuyang 于2024年1月19日周五 13:58写道: > +1 (non-binding)-- > > Best! > Xuyang > > > > > > 在 2024-01-19 13:28:52,"Lincoln Lee" 写道: > >+1 (binding) > > > >Best, > >Lincoln Lee > > > > > >Benchao Li 于2024年1月19日周五 13:15写道: > > > >> +1 (binding) > >> > >> shuai xu

Re: [VOTE] FLIP-416: Deprecate and remove the RestoreMode#LEGACY

2024-01-18 Thread Yun Tang
+1 (binding) Best Yun Tang From: Rui Fan <1996fan...@gmail.com> Sent: Friday, January 19, 2024 13:10 To: dev@flink.apache.org Subject: Re: [VOTE] FLIP-416: Deprecate and remove the RestoreMode#LEGACY +1 (binding) Best, Rui On Fri, Jan 19, 2024 at 12:15 PM

Re: [VOTE] FLIP-416: Deprecate and remove the RestoreMode#LEGACY

2024-01-18 Thread Hangxiang Yu
+1 (binding) On Fri, Jan 19, 2024 at 12:10 PM Zakelly Lan wrote: > Hi everyone, > > I'd like to start a vote on the FLIP-416: Deprecate and remove the > RestoreMode#LEGACY [1]. The discussion thread is here [2]. > > The vote will be open for at least 72 hours unless there is an objection or >

Re: [VOTE] FLIP-416: Deprecate and remove the RestoreMode#LEGACY

2024-01-18 Thread Yuan Mei
+1 binding Best Yuan On Fri, Jan 19, 2024 at 12:09 PM Zakelly Lan wrote: > Hi everyone, > > I'd like to start a vote on the FLIP-416: Deprecate and remove the > RestoreMode#LEGACY [1]. The discussion thread is here [2]. > > The vote will be open for at least 72 hours unless there is an

Re: [VOTE] FLIP-416: Deprecate and remove the RestoreMode#LEGACY

2024-01-18 Thread Rui Fan
+1 (binding) Best, Rui On Fri, Jan 19, 2024 at 12:15 PM Yanfei Lei wrote: > +1 (binding) > > Best, > Yanfei > > Hangxiang Yu 于2024年1月19日周五 12:13写道: > > > > +1 (binding) > > > > On Fri, Jan 19, 2024 at 12:10 PM Zakelly Lan > wrote: > > > > > Hi everyone, > > > > > > I'd like to start a vote

[jira] [Created] (FLINK-34166) KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty

2024-01-18 Thread lincoln lee (Jira)
lincoln lee created FLINK-34166: --- Summary: KeyedLookupJoinWrapper incorrectly process delete message for inner join when previous lookup result is empty Key: FLINK-34166 URL:

Re: FW: RE: [DISCUSS] FLIP-368 Reorganize the exceptions thrown in state interfaces

2024-01-18 Thread Zakelly Lan
Hi all, After rethinking, I‘ve come to agree that the Flink 2.0 would be a fittable version for this kind of change. I'd like to reopen this discussion for making this in 2.0. I suggest modifying the exception directly in Flink 2.0 rather than introducing a new set of APIs without any additional

Re: Re: [VOTE] FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources

2024-01-18 Thread Jark Wu
+1 (binding) Best, Jark On Tue, 16 Jan 2024 at 18:01, Xuyang wrote: > +1 (non-binding) > > > -- > > Best! > Xuyang > > > > > > 在 2024-01-16 17:52:38,"Leonard Xu" 写道: > >+1 (binding) > > > >Best, > >Leonard > > > >> 2024年1月16日 下午5:40,Hang Ruan 写道: > >> > >> +1 (non-binding) > >> > >>

[VOTE] FLIP-415: Introduce a new join operator to support minibatch

2024-01-18 Thread shuai xu
Dear Flink Developers, Thank you for providing feedback on FLIP-415: Introduce a new join operator to support minibatch[1]. I'd like to start a vote on this FLIP. Here is the discussion thread[2]. After the discussion, this FLIP will not introduce any new Option. The minibatch join will

Confluence access

2024-01-18 Thread Сергей Парышев
Hi devs! Can I get access to confluence? I want suggest a FLIP.

[jira] [Created] (FLINK-34167) add dependence to fit jdk21

2024-01-18 Thread blackpighe (Jira)
blackpighe created FLINK-34167: -- Summary: add dependence to fit jdk21 Key: FLINK-34167 URL: https://issues.apache.org/jira/browse/FLINK-34167 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-34148) Potential regression (Jan. 13): stringWrite with Java8

2024-01-18 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34148: --- Summary: Potential regression (Jan. 13): stringWrite with Java8 Key: FLINK-34148 URL: https://issues.apache.org/jira/browse/FLINK-34148 Project: Flink Issue

[jira] [Created] (FLINK-34149) Flink Kafka connector can't compile against 1.19-SNAPSHOT

2024-01-18 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34149: -- Summary: Flink Kafka connector can't compile against 1.19-SNAPSHOT Key: FLINK-34149 URL: https://issues.apache.org/jira/browse/FLINK-34149 Project: Flink

[jira] [Created] (FLINK-34150) file sink e2e tests with local setup are not executed if s3 credentials are not provided

2024-01-18 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34150: - Summary: file sink e2e tests with local setup are not executed if s3 credentials are not provided Key: FLINK-34150 URL: https://issues.apache.org/jira/browse/FLINK-34150

[jira] [Created] (FLINK-34146) JDBC lookup joins fail with RDB column names containing colons

2024-01-18 Thread david radley (Jira)
david radley created FLINK-34146: Summary: JDBC lookup joins fail with RDB column names containing colons Key: FLINK-34146 URL: https://issues.apache.org/jira/browse/FLINK-34146 Project: Flink

[jira] [Created] (FLINK-34145) File source connector support dynamic source parallelism inference in batch jobs

2024-01-18 Thread xingbe (Jira)
xingbe created FLINK-34145: -- Summary: File source connector support dynamic source parallelism inference in batch jobs Key: FLINK-34145 URL: https://issues.apache.org/jira/browse/FLINK-34145 Project: Flink

[RESULT][VOTE] Accept Flink CDC into Apache Flink

2024-01-18 Thread Leonard Xu
Hi all, Thank you for your enthusiastic participation! I am happy to announce that Flink CDC project contribution initiated by Ververica has been officially accepted[1] by the Apache Flink community. Result: - 32 PMC members voted, that is 2/3 of the total PMC members(48). - 31 non-PMC

[jira] [Created] (FLINK-34151) Integrate Karpenter resource limits into cluster capacity check

2024-01-18 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-34151: -- Summary: Integrate Karpenter resource limits into cluster capacity check Key: FLINK-34151 URL: https://issues.apache.org/jira/browse/FLINK-34151 Project:

[jira] [Created] (FLINK-34147) TimestampData to/from LocalDateTime is ambiguous

2024-01-18 Thread Rui Li (Jira)
Rui Li created FLINK-34147: -- Summary: TimestampData to/from LocalDateTime is ambiguous Key: FLINK-34147 URL: https://issues.apache.org/jira/browse/FLINK-34147 Project: Flink Issue Type: Bug

Re: Flink autoscaler scaling report

2024-01-18 Thread Yu Chen
Hi Yang, You can run `StandaloneAutoscalerEntrypoint`, and the scale report will print in log (info level) by LoggingEventHandler[2]. [1] flink-kubernetes-operator/flink-autoscaler-standalone/src/main/java/org/apache/flink/autoscaler/standalone/StandaloneAutoscalerEntrypoint.java at main ·

Re: [VOTE] Accept Flink CDC into Apache Flink

2024-01-18 Thread Leonard Xu
Thank you everyone for voting! The voting period has passed and we have enough binding votes! Thus I will close the voting and summarize the result in another email. Best, Leonard > 2024年1月17日 下午5:54,Swapnal Varma 写道: > > +1 (non-binding) > > Best, > Swapnal > > On Wed, Jan 17, 2024 at

[jira] [Created] (FLINK-34142) TaskManager WorkingDirectory is not removed during shutdown

2024-01-18 Thread Prabhu Joseph (Jira)
Prabhu Joseph created FLINK-34142: - Summary: TaskManager WorkingDirectory is not removed during shutdown Key: FLINK-34142 URL: https://issues.apache.org/jira/browse/FLINK-34142 Project: Flink

Flink autoscaler scaling report

2024-01-18 Thread Yang LI
Hello dear flink community, I noticed that there's a scaling report feature (specifically, the strings defined in AutoscalerEventHandler) in the Flink operator autoscaler. However, I'm unable to find this information in the Flink operator logs. Could anyone guide me on how to access or visualize

[jira] [Created] (FLINK-34143) Modify the effective strategy of `execution.batch.adaptive.auto-parallelism.default-source-parallelism`

2024-01-18 Thread xingbe (Jira)
xingbe created FLINK-34143: -- Summary: Modify the effective strategy of `execution.batch.adaptive.auto-parallelism.default-source-parallelism` Key: FLINK-34143 URL: https://issues.apache.org/jira/browse/FLINK-34143

[jira] [Created] (FLINK-34144) Update the documentation and configuration description about dynamic source parallelism inference

2024-01-18 Thread xingbe (Jira)
xingbe created FLINK-34144: -- Summary: Update the documentation and configuration description about dynamic source parallelism inference Key: FLINK-34144 URL: https://issues.apache.org/jira/browse/FLINK-34144

[jira] [Created] (FLINK-34153) Set ALWAYS ChainingStrategy in TemporalSort

2024-01-18 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-34153: Summary: Set ALWAYS ChainingStrategy in TemporalSort Key: FLINK-34153 URL: https://issues.apache.org/jira/browse/FLINK-34153 Project: Flink Issue

[jira] [Created] (FLINK-34152) Tune memory of autoscaled jobs

2024-01-18 Thread Maximilian Michels (Jira)
Maximilian Michels created FLINK-34152: -- Summary: Tune memory of autoscaled jobs Key: FLINK-34152 URL: https://issues.apache.org/jira/browse/FLINK-34152 Project: Flink Issue Type: New

[jira] [Created] (FLINK-34154) Bump org.apache.zookeeper:zookeeper from 3.5.9 to 3.7.2 for Kafka connector

2024-01-18 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34154: -- Summary: Bump org.apache.zookeeper:zookeeper from 3.5.9 to 3.7.2 for Kafka connector Key: FLINK-34154 URL: https://issues.apache.org/jira/browse/FLINK-34154

FLink runtime meeting some error,Hoping to give some solutions

2024-01-18 Thread 15868861416
| | 博星 | | | The specific error is as shown above.

[jira] [Created] (FLINK-34155) Recurring SqlExecutionException

2024-01-18 Thread Jeyhun Karimov (Jira)
Jeyhun Karimov created FLINK-34155: -- Summary: Recurring SqlExecutionException Key: FLINK-34155 URL: https://issues.apache.org/jira/browse/FLINK-34155 Project: Flink Issue Type: Bug

[DISCUSS] Mark org.apache.flink.util.Preconditions @Public

2024-01-18 Thread Alexander Fedulov
Hi everyone, pretty much every connector utilizes checks from the org.apache.flink.util.Preconditions class, which is currently marked as @Internal. This causes CONNECTOR_CLASSES_ONLY_DEPEND_ON_PUBLIC_API architecture tests to fail and results in the violation exceptions being filled with the

[jira] [Created] (FLINK-34157) Migrate FlinkLimit0RemoveRule

2024-01-18 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34157: --- Summary: Migrate FlinkLimit0RemoveRule Key: FLINK-34157 URL: https://issues.apache.org/jira/browse/FLINK-34157 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34159) Migrate ConstantRankNumberColumnRemoveRule

2024-01-18 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34159: --- Summary: Migrate ConstantRankNumberColumnRemoveRule Key: FLINK-34159 URL: https://issues.apache.org/jira/browse/FLINK-34159 Project: Flink Issue Type:

[jira] [Created] (FLINK-34161) Migrate RewriteMinusAllRule

2024-01-18 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34161: --- Summary: Migrate RewriteMinusAllRule Key: FLINK-34161 URL: https://issues.apache.org/jira/browse/FLINK-34161 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34163) Migrate SimplifyJoinConditionRule

2024-01-18 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34163: --- Summary: Migrate SimplifyJoinConditionRule Key: FLINK-34163 URL: https://issues.apache.org/jira/browse/FLINK-34163 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34156) Move Flink Calcite rules from Scala to Java

2024-01-18 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34156: --- Summary: Move Flink Calcite rules from Scala to Java Key: FLINK-34156 URL: https://issues.apache.org/jira/browse/FLINK-34156 Project: Flink Issue

Re: [DISCUSS] FLIP-417: Expose JobManagerOperatorMetrics via REST API

2024-01-18 Thread Mason Chen
Hi Lijie, That's also a possibility but I would prefer to keep it consistent with how the existing metric APIs are used. For example, in the current metric APIs [1], there is no way to figure out the vertexid and subtaskindex without getting the job graph from `/jobs//plan` and correspondingly

[jira] [Created] (FLINK-34158) Migrate WindowAggregateReduceFunctionsRule

2024-01-18 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34158: --- Summary: Migrate WindowAggregateReduceFunctionsRule Key: FLINK-34158 URL: https://issues.apache.org/jira/browse/FLINK-34158 Project: Flink Issue Type:

[jira] [Created] (FLINK-34160) Migrate FlinkCalcMergeRule

2024-01-18 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34160: --- Summary: Migrate FlinkCalcMergeRule Key: FLINK-34160 URL: https://issues.apache.org/jira/browse/FLINK-34160 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34162) Migrate LogicalUnnestRule

2024-01-18 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-34162: --- Summary: Migrate LogicalUnnestRule Key: FLINK-34162 URL: https://issues.apache.org/jira/browse/FLINK-34162 Project: Flink Issue Type: Sub-task

Re: [VOTE] FLIP-389: Annotate SingleThreadFetcherManager as PublicEvolving

2024-01-18 Thread Qingsheng Ren
+1 (binding) Thanks for the work, Hongshun! Best, Qingsheng On Tue, Jan 16, 2024 at 11:21 AM Leonard Xu wrote: > Thanks Hongshun for driving this ! > > +1(binding) > > Best, > Leonard > > > 2024年1月3日 下午8:04,Hongshun Wang 写道: > > > > Dear Flink Developers, > > > > Thank you for providing

Re: [DISCUSS] FLIP-389: Annotate SingleThreadFetcherManager and FutureCompletingBlockingQueue as PublicEvolving

2024-01-18 Thread Hongshun Wang
Hi Devs, Thanks for all your advice, it helps a lot. I have already revised the document[1] and started a vote[2]. Thanks, Hongshun [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=278465498 [2] https://lists.apache.org/thread/t1zff21z440pvv48jyhm8pgtqsyplchn On

退订

2024-01-18 Thread 李乐
退订