Re: [PR] [FLINK-32611] Redirect to Apache Paimon's link instead of legacy flink table store [flink-web]

2023-10-20 Thread via GitHub
Myasuka commented on code in PR #665: URL: https://github.com/apache/flink-web/pull/665#discussion_r1367670600 ## docs/content/documentation/flink-table-store-0.3.md: ## @@ -1,7 +1,7 @@ --- -weight: 10 -title: Table Store Master (snapshot) -bookHref:

Re: [PR] [FLINK-33007] Integrate autoscaler config validation into the general validator flow [flink-kubernetes-operator]

2023-10-20 Thread via GitHub
srpraneeth commented on PR #682: URL: https://github.com/apache/flink-kubernetes-operator/pull/682#issuecomment-1773677537 Refactored after the merge of PR #677 @gyfora -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Commented] (FLINK-24696) Translate how to configure unaligned checkpoints into Chinese

2023-10-20 Thread lijie (Jira)
[ https://issues.apache.org/jira/browse/FLINK-24696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778005#comment-17778005 ] lijie commented on FLINK-24696: --- Sorry, I was wrong. I found that I modified the wrong version. I will

[PR] [release] Update the doc version to 1.6.1 [flink-kubernetes-operator]

2023-10-20 Thread via GitHub
1996fanrui opened a new pull request, #687: URL: https://github.com/apache/flink-kubernetes-operator/pull/687 Note: it can be merged after 1.6.1 is released. Update the doc version to 1.6.1 -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [FLINK-33187] using hashcode for parallelism map comparison [flink-kubernetes-operator]

2023-10-20 Thread via GitHub
1996fanrui commented on code in PR #685: URL: https://github.com/apache/flink-kubernetes-operator/pull/685#discussion_r1367619403 ## flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/autoscaler/KubernetesAutoScalerEventHandler.java: ## @@ -43,26

Re: [PR] [FLINK-32896][Runtime/Coordination] Incorrect `Map.computeIfAbsent(..., ...::new)` usage which misinterprets key as initial capacity [flink]

2023-10-20 Thread via GitHub
tzy-0x7cf commented on PR #23518: URL: https://github.com/apache/flink/pull/23518#issuecomment-1773621479 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-32896][Runtime/Coordination] Incorrect `Map.computeIfAbsent(..., ...::new)` usage which misinterprets key as initial capacity [flink]

2023-10-20 Thread via GitHub
tzy-0x7cf commented on PR #23518: URL: https://github.com/apache/flink/pull/23518#issuecomment-1773618695 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] [FLINK-33090][checkpointing] CheckpointsCleaner clean individual chec… [flink]

2023-10-20 Thread via GitHub
yigress commented on code in PR #23425: URL: https://github.com/apache/flink/pull/23425#discussion_r1367568947 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointsCleaner.java: ## @@ -71,10 +81,19 @@ public void cleanCheckpoint( boolean

Re: [PR] [FLINK-33090][checkpointing] CheckpointsCleaner clean individual chec… [flink]

2023-10-20 Thread via GitHub
yigress commented on code in PR #23425: URL: https://github.com/apache/flink/pull/23425#discussion_r1367568908 ## flink-core/src/main/java/org/apache/flink/configuration/CheckpointingOptions.java: ## @@ -109,6 +109,19 @@ public class CheckpointingOptions {

[jira] [Closed] (FLINK-33321) VertexFlameGraphFactoryTest#verifyRecursively fails on Java 21

2023-10-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-33321. --- > VertexFlameGraphFactoryTest#verifyRecursively fails on Java 21 >

[jira] [Commented] (FLINK-33311) FlinkSecurityManagerITCase fails on java 21

2023-10-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1992#comment-1992 ] Sergey Nuyanzin commented on FLINK-33311: - yep, you're right > FlinkSecurityManagerITCase fails

Re: [PR] [FLINK-33334][table] Make map entries sorted by keys in json plan to have it stable for java21 [flink]

2023-10-20 Thread via GitHub
flinkbot commented on PR #23562: URL: https://github.com/apache/flink/pull/23562#issuecomment-1773510881 ## CI report: * 4567aac08a4e53a6e9fb9b5cd70da58ae1829032 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33334) A number of json plan tests fail with comparisonfailure

2023-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-4: --- Labels: pull-request-available (was: ) > A number of json plan tests fail with

[jira] [Assigned] (FLINK-33334) A number of json plan tests fail with comparisonfailure

2023-10-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-4?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-4: --- Assignee: Sergey Nuyanzin > A number of json plan tests fail with

[jira] [Closed] (FLINK-33333) TableSinkJsonPlanTest fails as JsonParseException: Unexpected character ('"' (code 34)): was expecting comma

2023-10-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin closed FLINK-3. --- Release Note: created by mistake Resolution: Fixed > TableSinkJsonPlanTest fails as

[PR] [FLINK-33334][table] Make map entries sorted by keys in json plan to have it stable for java21 [flink]

2023-10-20 Thread via GitHub
snuyanzin opened a new pull request, #23562: URL: https://github.com/apache/flink/pull/23562 ## What is the purpose of the change The problem of current `JsonSerdeUtil` is that it does not define any order how map entries should be serialized to json plan . As a result in java 21

[jira] [Created] (FLINK-33334) A number of json plan tests fail with comparisonfailure

2023-10-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-4: --- Summary: A number of json plan tests fail with comparisonfailure Key: FLINK-4 URL: https://issues.apache.org/jira/browse/FLINK-4 Project: Flink

[jira] [Created] (FLINK-33333) TableSinkJsonPlanTest fails as JsonParseException: Unexpected character ('"' (code 34)): was expecting comma

2023-10-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-3: --- Summary: TableSinkJsonPlanTest fails as JsonParseException: Unexpected character ('"' (code 34)): was expecting comma Key: FLINK-3 URL:

[jira] [Updated] (FLINK-33332) AssertionError: Exception in test: sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available

2023-10-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-2?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-2: Description: A couple of tests in flink-python fail like {noformat}

[jira] [Created] (FLINK-33332) AssertionError: Exception in test: sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available

2023-10-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-2: --- Summary: AssertionError: Exception in test: sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available Key: FLINK-2 URL:

[jira] [Updated] (FLINK-33331) NoClassDefFoundError: Could not initialize class org.apache.flink.table.runtime.arrow.serializers.ArrowSerializer

2023-10-20 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-1: Description: A number of tests fails like e.g.for

[jira] [Created] (FLINK-33331) NoClassDefFoundError: Could not initialize class org.apache.flink.table.runtime.arrow.serializers.ArrowSerializer

2023-10-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-1: --- Summary: NoClassDefFoundError: Could not initialize class org.apache.flink.table.runtime.arrow.serializers.ArrowSerializer Key: FLINK-1 URL:

Re: [PR] [FLINK-32896][Runtime/Coordination] Incorrect `Map.computeIfAbsent(..., ...::new)` usage which misinterprets key as initial capacity [flink]

2023-10-20 Thread via GitHub
tzy-0x7cf commented on PR #23518: URL: https://github.com/apache/flink/pull/23518#issuecomment-1773422247 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

[jira] [Updated] (FLINK-33330) Bump zookeeper to address CVE-2023-44981

2023-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-0?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-0: --- Labels: pull-request-available (was: ) > Bump zookeeper to address CVE-2023-44981 >

[jira] [Created] (FLINK-33330) Bump zookeeper to address CVE-2023-44981

2023-10-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-0: --- Summary: Bump zookeeper to address CVE-2023-44981 Key: FLINK-0 URL: https://issues.apache.org/jira/browse/FLINK-0 Project: Flink Issue Type:

Re: [PR] [FLINK-33187] using hashcode for parallelism map comparison [flink-kubernetes-operator]

2023-10-20 Thread via GitHub
clarax commented on code in PR #685: URL: https://github.com/apache/flink-kubernetes-operator/pull/685#discussion_r1367373231 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoScalerEventHandler.java: ## @@ -33,19 +35,15 @@ @Experimental public

Re: [PR] [FLINK-33329] Upgrade commons-compress to 1.24.0 [flink]

2023-10-20 Thread via GitHub
flinkbot commented on PR #23561: URL: https://github.com/apache/flink/pull/23561#issuecomment-1773179287 ## CI report: * c05285630f0c00de695cfe5e18ba5d2083f4762e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-33329) Bump commons-compress to address CVEs

2023-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33329: --- Labels: pull-request-available (was: ) > Bump commons-compress to address CVEs >

[PR] [FLINK-33329] Upgrade commons-compress to 1.24.0 [flink]

2023-10-20 Thread via GitHub
snuyanzin opened a new pull request, #23561: URL: https://github.com/apache/flink/pull/23561 ## What is the purpose of the change The PR is addressing CVE-2023-42503 ## Verifying this change This change is a trivial rework ## Does this pull request

[jira] [Created] (FLINK-33329) Bump commons-compress to address CVEs

2023-10-20 Thread Sergey Nuyanzin (Jira)
Sergey Nuyanzin created FLINK-33329: --- Summary: Bump commons-compress to address CVEs Key: FLINK-33329 URL: https://issues.apache.org/jira/browse/FLINK-33329 Project: Flink Issue Type:

Re: [PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-20 Thread via GitHub
knaufk commented on PR #680: URL: https://github.com/apache/flink-web/pull/680#issuecomment-1773018935 > Thanks for the PR, @knaufk. > > I wonder if we should add a paragraph about the deprecation works. Many APIs are deprecated in 1.18 as preparing for the 2.0 release. It might be

[jira] [Commented] (FLINK-20955) Refactor HBase Source in accordance with FLIP-27

2023-10-20 Thread Ryan Skraba (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20955?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1853#comment-1853 ] Ryan Skraba commented on FLINK-20955: - Hey – I see there's a PR on apache/flink, with a couple

Re: [PR] [FLINK-33327] Window TVF column expansion does not work with an INSERT INTO [flink]

2023-10-20 Thread via GitHub
dawidwys merged PR #23560: URL: https://github.com/apache/flink/pull/23560 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-33327) Window TVF column expansion does not work with an INSERT INTO

2023-10-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-33327. Resolution: Fixed Fixed in c7beda0da81ffc4bbb01befafd2eed08b7b35854 > Window TVF column

Re: [PR] [FLINK-33187] using hashcode for parallelism map comparison [flink-kubernetes-operator]

2023-10-20 Thread via GitHub
gyfora commented on code in PR #685: URL: https://github.com/apache/flink-kubernetes-operator/pull/685#discussion_r1367164471 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoScalerEventHandler.java: ## @@ -33,19 +35,15 @@ @Experimental public

Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink]

2023-10-20 Thread via GitHub
gyfora commented on code in PR #23490: URL: https://github.com/apache/flink/pull/23490#discussion_r1367160740 ## pom.xml: ## @@ -205,6 +205,7 @@ under the License. **/*Test.* + **/Java17*.java Review Comment: I

Re: [PR] [FLINK-33187] using hashcode for parallelism map comparison [flink-kubernetes-operator]

2023-10-20 Thread via GitHub
clarax commented on code in PR #685: URL: https://github.com/apache/flink-kubernetes-operator/pull/685#discussion_r1367157112 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/event/AutoScalerEventHandler.java: ## @@ -33,19 +35,15 @@ @Experimental public

Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink]

2023-10-20 Thread via GitHub
gyfora commented on code in PR #23490: URL: https://github.com/apache/flink/pull/23490#discussion_r1367144799 ## pom.xml: ## @@ -1102,6 +1103,12 @@ under the License. java17-target + + +

Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink]

2023-10-20 Thread via GitHub
XComp commented on code in PR #23490: URL: https://github.com/apache/flink/pull/23490#discussion_r1365688252 ## flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/JavaRecordSerializationHelper.java: ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink]

2023-10-20 Thread via GitHub
XComp commented on code in PR #23490: URL: https://github.com/apache/flink/pull/23490#discussion_r1367089252 ## flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/JavaRecordSerializationHelper.java: ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software

[jira] [Comment Edited] (FLINK-33301) Add Java and Maven version checks in the bash script of Flink release process

2023-10-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1817#comment-1817 ] Matthias Pohl edited comment on FLINK-33301 at 10/20/23 2:45 PM: -

[jira] [Comment Edited] (FLINK-33301) Add Java and Maven version checks in the bash script of Flink release process

2023-10-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1817#comment-1817 ] Matthias Pohl edited comment on FLINK-33301 at 10/20/23 2:44 PM: -

[jira] [Commented] (FLINK-33301) Add Java and Maven version checks in the bash script of Flink release process

2023-10-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1817#comment-1817 ] Matthias Pohl commented on FLINK-33301: ---

Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink]

2023-10-20 Thread via GitHub
gyfora commented on code in PR #23490: URL: https://github.com/apache/flink/pull/23490#discussion_r1367029934 ## flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/JavaRecordSerializationHelper.java: ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink]

2023-10-20 Thread via GitHub
gyfora commented on code in PR #23490: URL: https://github.com/apache/flink/pull/23490#discussion_r1367026908 ## flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/JavaRecordSerializationHelper.java: ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink]

2023-10-20 Thread via GitHub
gyfora commented on code in PR #23490: URL: https://github.com/apache/flink/pull/23490#discussion_r1367025531 ## flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/JavaRecordSerializationHelper.java: ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-32380] Support Java Records with PojoTypeInfo/Serializer [flink]

2023-10-20 Thread via GitHub
gyfora commented on code in PR #23490: URL: https://github.com/apache/flink/pull/23490#discussion_r1367023415 ## flink-core/src/main/java/org/apache/flink/api/java/typeutils/runtime/JavaRecordSerializationHelper.java: ## @@ -0,0 +1,151 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (FLINK-32694) Migrate classes that implement ParallelSourceFunction to Source V2 API

2023-10-20 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-32694: -- Description:   * SimpleEndlessSourceWithBloatedState in

Re: [PR] [FLINK-33274][release] Add release note for version 1.18 [flink]

2023-10-20 Thread via GitHub
XComp commented on code in PR #23527: URL: https://github.com/apache/flink/pull/23527#discussion_r1367001376 ## docs/content/release-notes/flink-1.18.md: ## @@ -0,0 +1,152 @@ +--- +title: "Release Notes - Flink 1.18" +--- + + +# Release notes - Flink 1.18 + +These release notes

Re: [PR] Fix ClickEventCount for parallelism higher than 1 [flink-playgrounds]

2023-10-20 Thread via GitHub
alpinegizmo commented on PR #43: URL: https://github.com/apache/flink-playgrounds/pull/43#issuecomment-1772773331 Thank you @tudorpavel for reporting and fixing this! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] Fix ClickEventCount for parallelism higher than 1 [flink-playgrounds]

2023-10-20 Thread via GitHub
alpinegizmo merged PR #43: URL: https://github.com/apache/flink-playgrounds/pull/43 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-28050][connectors] Migrate StreamExecutionEnvironment#fromElements() implementation to FLIP-27 Source API [flink]

2023-10-20 Thread via GitHub
afedulov commented on PR #23553: URL: https://github.com/apache/flink/pull/23553#issuecomment-1772756912 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific

Re: [PR] Draft: FLINK-28229 (CI) [flink]

2023-10-20 Thread via GitHub
afedulov commented on PR #23558: URL: https://github.com/apache/flink/pull/23558#issuecomment-1772755799 @flinkbot run azure -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

[jira] [Comment Edited] (FLINK-33324) Add flink managed timeout mechanism for backend restore operation

2023-10-20 Thread dongwoo.kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1755#comment-1755 ] dongwoo.kim edited comment on FLINK-33324 at 10/20/23 1:25 PM: --- Hi,

[jira] [Comment Edited] (FLINK-33324) Add flink managed timeout mechanism for backend restore operation

2023-10-20 Thread dongwoo.kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1755#comment-1755 ] dongwoo.kim edited comment on FLINK-33324 at 10/20/23 1:24 PM: --- Hi,

Re: [PR] add announcement blog post for Flink 1.18 [flink-web]

2023-10-20 Thread via GitHub
XComp commented on code in PR #680: URL: https://github.com/apache/flink-web/pull/680#discussion_r1366955062 ## docs/content/posts/2023-10-10-release-1.18.0.md: ## @@ -0,0 +1,554 @@ +--- +authors: +- JingGe: + name: "Jing Ge" + twitter: jingengineer +- KonstantinKnauf: +

Re: [PR] [FLINK-33327] Window TVF column expansion does not work with an INSERT INTO [flink]

2023-10-20 Thread via GitHub
flinkbot commented on PR #23560: URL: https://github.com/apache/flink/pull/23560#issuecomment-1772726032 ## CI report: * d7a61a800520ccc6c4bc17580092ad17de758929 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-33324) Add flink managed timeout mechanism for backend restore operation

2023-10-20 Thread dongwoo.kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1757#comment-1757 ] dongwoo.kim commented on FLINK-33324: - Hi, [~roman]  Thanks for considering my suggestion. For some

[jira] [Commented] (FLINK-33324) Add flink managed timeout mechanism for backend restore operation

2023-10-20 Thread dongwoo.kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1756#comment-1756 ] dongwoo.kim commented on FLINK-33324: - Hi, [~Zakelly]  Thanks for sharing your opinion and

[jira] [Updated] (FLINK-33327) Window TVF column expansion does not work with an INSERT INTO

2023-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33327: --- Labels: pull-request-available (was: ) > Window TVF column expansion does not work with an

[PR] [FLINK-33327] Window TVF column expansion does not work with an INSERT INTO [flink]

2023-10-20 Thread via GitHub
dawidwys opened a new pull request, #23560: URL: https://github.com/apache/flink/pull/23560 ## What is the purpose of the change Fixes expanding explicit columns if the `TableFunction` is resolved. ## Verifying this change Added test:

[jira] [Commented] (FLINK-33324) Add flink managed timeout mechanism for backend restore operation

2023-10-20 Thread dongwoo.kim (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1755#comment-1755 ] dongwoo.kim commented on FLINK-33324: - Hi, [~pnowojski]  Thanks for the opinion.  First about the

[jira] [Updated] (FLINK-28045) [umbrella] Blockers for SourceFunction API removal (in Flink 2.0)

2023-10-20 Thread Alexander Fedulov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alexander Fedulov updated FLINK-28045: -- Description: This ticket should only contain items where SourceFunction is already

[jira] [Created] (FLINK-33328) Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable

2023-10-20 Thread Peter Vary (Jira)
Peter Vary created FLINK-33328: -- Summary: Allow TwoPhaseCommittingSink WithPreCommitTopology to alter the type of the Committable Key: FLINK-33328 URL: https://issues.apache.org/jira/browse/FLINK-33328

[jira] [Created] (FLINK-33327) Window TVF column expansion does not work with an INSERT INTO

2023-10-20 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-33327: Summary: Window TVF column expansion does not work with an INSERT INTO Key: FLINK-33327 URL: https://issues.apache.org/jira/browse/FLINK-33327 Project: Flink

[jira] [Updated] (FLINK-33327) Window TVF column expansion does not work with an INSERT INTO

2023-10-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-33327: - Description: If we have an {{INSERT INTO}} with an explicit column list and a

[jira] [Assigned] (FLINK-33327) Window TVF column expansion does not work with an INSERT INTO

2023-10-20 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reassigned FLINK-33327: Assignee: Dawid Wysakowicz > Window TVF column expansion does not work with an

[jira] [Comment Edited] (FLINK-32716) Give 'Default'(or maybe 'None') option for 'scheduler-mode'

2023-10-20 Thread Kwangin (Dennis) Jung (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1723#comment-1723 ] Kwangin (Dennis) Jung edited comment on FLINK-32716 at 10/20/23 11:50 AM:

[jira] [Commented] (FLINK-32716) Give 'Default'(or maybe 'None') option for 'scheduler-mode'

2023-10-20 Thread Kwangin (Dennis) Jung (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1723#comment-1723 ] Kwangin (Dennis) Jung commented on FLINK-32716: --- [~paul8263]  > The issue ID in your

Re: [PR] [FLINK-32107] [Tests] Kubernetes test failed because ofunable to establish ssl connection to github on AZP [flink]

2023-10-20 Thread via GitHub
XComp commented on code in PR #23528: URL: https://github.com/apache/flink/pull/23528#discussion_r1366863438 ## flink-end-to-end-tests/test-scripts/common_kubernetes.sh: ## @@ -39,8 +39,12 @@ function setup_kubernetes_for_linux { if ! [ -x "$(command -v kubectl)" ]; then

Re: [PR] [FLINK-31180] [Test Infrastructure] Fail early when installing minikube and check whether we can retry [flink]

2023-10-20 Thread via GitHub
XComp commented on PR #23497: URL: https://github.com/apache/flink/pull/23497#issuecomment-1772581309 Thanks for addressing my comment. It looks like the retry mechanism doesn't work properly, yet. Please see my comments above. -- This is an automated message from the Apache Git Service.

[jira] [Closed] (FLINK-33307) Disable spotless on Java 21

2023-10-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-33307. Fix Version/s: 1.19.0 Assignee: Sergey Nuyanzin Resolution: Fixed master:

[jira] [Closed] (FLINK-33308) Upgrade lombok to 1.8.30

2023-10-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-33308. Fix Version/s: 1.19.0 Resolution: Fixed master:

[jira] [Commented] (FLINK-33311) FlinkSecurityManagerITCase fails on java 21

2023-10-20 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1715#comment-1715 ] Chesnay Schepler commented on FLINK-33311: -- I assume these failed after FLINK-33309? >

Re: [PR] [FLINK-31180] [Test Infrastructure] Fail early when installing minikube and check whether we can retry [flink]

2023-10-20 Thread via GitHub
XComp commented on code in PR #23497: URL: https://github.com/apache/flink/pull/23497#discussion_r1366857711 ## flink-end-to-end-tests/test-scripts/common_kubernetes.sh: ## @@ -48,10 +48,15 @@ function setup_kubernetes_for_linux { sudo rm "$(which minikube)" fi +

Re: [PR] [FLINK-33307] Disable spotless on Java 21 [flink]

2023-10-20 Thread via GitHub
zentol merged PR #23546: URL: https://github.com/apache/flink/pull/23546 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Updated] (FLINK-33308) Upgrade lombok to 1.8.30

2023-10-20 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33308: --- Labels: pull-request-available (was: ) > Upgrade lombok to 1.8.30 >

Re: [PR] [FLINK-33308] Upgrade lombok to 1.8.30 [flink]

2023-10-20 Thread via GitHub
zentol merged PR #23545: URL: https://github.com/apache/flink/pull/23545 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

[jira] [Commented] (FLINK-33238) Upgrade org.apache.avro:avro to 1.11.3 to mitigate CVE-2023-39410

2023-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33238?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1704#comment-1704 ] Martijn Visser commented on FLINK-33238: [~leibov...@rogers.com] I'll backport this to 1.18 for

[jira] [Reopened] (FLINK-33238) Upgrade org.apache.avro:avro to 1.11.3 to mitigate CVE-2023-39410

2023-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reopened FLINK-33238: > Upgrade org.apache.avro:avro to 1.11.3 to mitigate CVE-2023-39410 >

[jira] [Updated] (FLINK-33238) Upgrade org.apache.avro:avro to 1.11.3 to mitigate CVE-2023-39410

2023-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser updated FLINK-33238: --- Fix Version/s: 1.19.0 1.18.1 > Upgrade org.apache.avro:avro to 1.11.3 to

[jira] [Closed] (FLINK-33303) [flink-avro] Union type not inheriting type conversions

2023-10-20 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-33303. -- Resolution: Done Fixed via FLINK-33238 > [flink-avro] Union type not inheriting type

Re: [PR] [FLINK-33303] [flink-avro] Union type not inheriting type conversions [flink]

2023-10-20 Thread via GitHub
MartijnVisser closed pull request #23524: [FLINK-33303] [flink-avro] Union type not inheriting type conversions URL: https://github.com/apache/flink/pull/23524 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

Re: [PR] [FLINK-33303] [flink-avro] Union type not inheriting type conversions [flink]

2023-10-20 Thread via GitHub
MartijnVisser commented on PR #23524: URL: https://github.com/apache/flink/pull/23524#issuecomment-1772528352 Fixed by https://github.com/apache/flink/pull/23508 - Will be backported to 1.18 (so for 1.18.1) with https://github.com/apache/flink/pull/23559 -- This is an automated message

Re: [PR] [FLINK-33238][Formats/Avro] Upgrade used AVRO version to 1.11.3 [flink]

2023-10-20 Thread via GitHub
MartijnVisser merged PR #23508: URL: https://github.com/apache/flink/pull/23508 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-33238][Formats/Avro] Upgrade used AVRO version to 1.11.3 [flink]

2023-10-20 Thread via GitHub
MartijnVisser commented on code in PR #23508: URL: https://github.com/apache/flink/pull/23508#discussion_r1366820432 ## flink-formats/flink-avro/src/test/java/org/apache/flink/formats/avro/RegistryAvroDeserializationSchemaTest.java: ## @@ -85,7 +85,7 @@ void

[jira] [Resolved] (FLINK-33116) CliClientTest.testCancelExecutionInteractiveMode fails with NPE on AZP

2023-10-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-33116. --- Fix Version/s: 1.16.3 1.17.2 1.19.0

Re: [PR] [FLINK-33116][tests][release-1.16] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE [flink]

2023-10-20 Thread via GitHub
XComp merged PR #23535: URL: https://github.com/apache/flink/pull/23535 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-33116][tests][release-1.17] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE [flink]

2023-10-20 Thread via GitHub
XComp merged PR #23534: URL: https://github.com/apache/flink/pull/23534 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-33116][tests][release-1.18] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE [flink]

2023-10-20 Thread via GitHub
XComp merged PR #23533: URL: https://github.com/apache/flink/pull/23533 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-33116][tests] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE [flink]

2023-10-20 Thread via GitHub
XComp merged PR #23515: URL: https://github.com/apache/flink/pull/23515 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail:

Re: [PR] [FLINK-33116][tests][release-1.15] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE [flink]

2023-10-20 Thread via GitHub
Jiabao-Sun commented on PR #23536: URL: https://github.com/apache/flink/pull/23536#issuecomment-1772516356 > 1.15 is not supported anymore. I'm gonna close this one without merging. OK. Thanks. -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [FLINK-33116][tests][release-1.15] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE [flink]

2023-10-20 Thread via GitHub
XComp closed pull request #23536: [FLINK-33116][tests][release-1.15] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE URL: https://github.com/apache/flink/pull/23536 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-33116][tests][release-1.15] Fix CliClientTest.testCancelExecutionInteractiveMode fails with NPE [flink]

2023-10-20 Thread via GitHub
XComp commented on PR #23536: URL: https://github.com/apache/flink/pull/23536#issuecomment-1772514043 1.15 is not supported anymore. I'm gonna close this one without merging. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

Re: [PR] [FLINK-32073][checkpoint] Implement file merging in snapshot [flink]

2023-10-20 Thread via GitHub
AlexYinHan commented on code in PR #23514: URL: https://github.com/apache/flink/pull/23514#discussion_r1366803327 ## flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/filemerging/FileMergingSnapshotManagerTest.java: ## @@ -249,6 +261,104 @@ void

[jira] [Created] (FLINK-33326) Remove usage of FromElementsFunction

2023-10-20 Thread Alexander Fedulov (Jira)
Alexander Fedulov created FLINK-33326: - Summary: Remove usage of FromElementsFunction Key: FLINK-33326 URL: https://issues.apache.org/jira/browse/FLINK-33326 Project: Flink Issue Type:

Re: [PR] [FLINK-32073][checkpoint] Implement file merging in snapshot [flink]

2023-10-20 Thread via GitHub
AlexYinHan commented on code in PR #23514: URL: https://github.com/apache/flink/pull/23514#discussion_r1366799573 ## flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/filemerging/SegmentFileStateHandle.java: ## @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-32073][checkpoint] Implement file merging in snapshot [flink]

2023-10-20 Thread via GitHub
AlexYinHan commented on code in PR #23514: URL: https://github.com/apache/flink/pull/23514#discussion_r1366799252 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FileMergingCheckpointStateOutputStream.java: ## @@ -0,0 +1,255 @@ +/* + * Licensed to the

[jira] [Comment Edited] (FLINK-33291) The release profile of Flink does include enforcing the Java version only in a "soft" way

2023-10-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1693#comment-1693 ] Matthias Pohl edited comment on FLINK-33291 at 10/20/23 10:29 AM: --

[jira] [Resolved] (FLINK-33291) The release profile of Flink does include enforcing the Java version only in a "soft" way

2023-10-20 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-33291. --- Fix Version/s: 1.18.0 1.16.3 1.17.2

  1   2   >