[jira] [Updated] (FLINK-34427) FineGrainedSlotManagerTest fails fatally (exit code 239)

2024-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl updated FLINK-34427: -- Summary: FineGrainedSlotManagerTest fails fatally (exit code 239) (was:

Re: [PR] [FLINK-33506] Add support for jdk17 for AWS connectors [flink-connector-aws]

2024-02-13 Thread via GitHub
z3d1k commented on code in PR #115: URL: https://github.com/apache/flink-connector-aws/pull/115#discussion_r1487577315 ## flink-connector-aws/flink-connector-dynamodb/pom.xml: ## @@ -34,6 +34,9 @@ under the License. jar + +

Re: [PR] [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode [flink]

2024-02-13 Thread via GitHub
ferenc-csaky commented on code in PR #24303: URL: https://github.com/apache/flink/pull/24303#discussion_r1487552348 ## flink-kubernetes/src/main/java/org/apache/flink/kubernetes/artifact/DefaultKubernetesArtifactUploader.java: ## @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode [flink]

2024-02-13 Thread via GitHub
schevalley2 commented on code in PR #24303: URL: https://github.com/apache/flink/pull/24303#discussion_r1487540063 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesClusterDescriptorTest.java: ## @@ -86,7 +86,8 @@ public FlinkKubeClient fromConfiguration(

Re: [PR] [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode [flink]

2024-02-13 Thread via GitHub
schevalley2 commented on code in PR #24303: URL: https://github.com/apache/flink/pull/24303#discussion_r1487538828 ## flink-kubernetes/src/main/java/org/apache/flink/kubernetes/artifact/DefaultKubernetesArtifactUploader.java: ## @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode [flink]

2024-02-13 Thread via GitHub
ferenc-csaky commented on code in PR #24303: URL: https://github.com/apache/flink/pull/24303#discussion_r1487526406 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesClusterDescriptorTest.java: ## @@ -86,7 +86,8 @@ public FlinkKubeClient fromConfiguration(

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816945#comment-17816945 ] Martijn Visser commented on FLINK-34282: Nice, thanks [~jingge]! > Create a release branch >

[jira] [Resolved] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

2024-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-34403. --- Fix Version/s: 1.20.0 Resolution: Fixed master:

[jira] [Commented] (FLINK-34399) Release Testing: Verify FLINK-33644 Make QueryOperations SQL serializable

2024-02-13 Thread Ferenc Csaky (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816940#comment-17816940 ] Ferenc Csaky commented on FLINK-34399: -- Hi! I can take this task, would someone be able to help and

Re: [PR] [FLINK-34403][ci] Transforms VeryBigPbProtoToRowTest into an integration test [flink]

2024-02-13 Thread via GitHub
XComp commented on code in PR #24302: URL: https://github.com/apache/flink/pull/24302#discussion_r1487496290 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/VeryBigPbProtoToRowITCase.java: ## @@ -25,8 +25,11 @@ /** * Test for very huge proto

Re: [PR] [FLINK-34403][ci] Transforms VeryBigPbProtoToRowTest into an integration test [flink]

2024-02-13 Thread via GitHub
XComp merged PR #24302: URL: https://github.com/apache/flink/pull/24302 -- 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-34418) Disk space issues for Docker-ized GitHub Action jobs

2024-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816937#comment-17816937 ] Matthias Pohl commented on FLINK-34418: --- https://github.com/apache/flink/actions/runs/7880739758

Re: [PR] [FLINK-34403][ci] Transforms VeryBigPbProtoToRowTest into an integration test [flink]

2024-02-13 Thread via GitHub
snuyanzin commented on code in PR #24302: URL: https://github.com/apache/flink/pull/24302#discussion_r1487487950 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/VeryBigPbProtoToRowITCase.java: ## @@ -25,8 +25,11 @@ /** * Test for very huge

[jira] [Commented] (FLINK-32006) AsyncWaitOperatorTest.testProcessingTimeWithTimeoutFunctionOrderedWithRetry times out on Azure

2024-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816935#comment-17816935 ] Matthias Pohl commented on FLINK-32006: --- 1.18:

Re: [PR] [FLINK-34403][ci] Transforms VeryBigPbProtoToRowTest into an integration test [flink]

2024-02-13 Thread via GitHub
snuyanzin commented on code in PR #24302: URL: https://github.com/apache/flink/pull/24302#discussion_r1487487950 ## flink-formats/flink-protobuf/src/test/java/org/apache/flink/formats/protobuf/VeryBigPbProtoToRowITCase.java: ## @@ -25,8 +25,11 @@ /** * Test for very huge

[jira] [Created] (FLINK-34433) CollectionFunctionsITCase.test failed due to job restart

2024-02-13 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-34433: - Summary: CollectionFunctionsITCase.test failed due to job restart Key: FLINK-34433 URL: https://issues.apache.org/jira/browse/FLINK-34433 Project: Flink

[jira] [Assigned] (FLINK-34403) VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM

2024-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl reassigned FLINK-34403: - Assignee: Matthias Pohl > VeryBigPbProtoToRowTest#testSimple cannot pass due to OOM >

[jira] [Commented] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-02-13 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816929#comment-17816929 ] Danny Cranmer commented on FLINK-34429: --- Thanks for raising [~bara...@gmail.com] , assigning to

[jira] [Assigned] (FLINK-34429) Adding K8S Annotations to Internal Service

2024-02-13 Thread Danny Cranmer (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Danny Cranmer reassigned FLINK-34429: - Assignee: Barak Ben-Nathan > Adding K8S Annotations to Internal Service >

[jira] [Commented] (FLINK-28440) EventTimeWindowCheckpointingITCase failed with restore

2024-02-13 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816928#comment-17816928 ] Matthias Pohl commented on FLINK-28440: ---

Re: [PR] Bump org.yaml:snakeyaml from 1.31 to 2.0 [flink-connector-elasticsearch]

2024-02-13 Thread via GitHub
snuyanzin commented on PR #90: URL: https://github.com/apache/flink-connector-elasticsearch/pull/90#issuecomment-1940820849 @MartijnVisser >since SnakeYAML requires JDK17 where did you get this info? here it is a quote from official SnakeYAML readme [1] >SnakeYAML is a

[jira] [Commented] (FLINK-34282) Create a release branch

2024-02-13 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816910#comment-17816910 ] Jing Ge commented on FLINK-34282: - [AzureCI project

Re: [PR] [FLINK-34386][state] Add RocksDB bloom filter metrics [flink]

2024-02-13 Thread via GitHub
hejufang commented on PR #24274: URL: https://github.com/apache/flink/pull/24274#issuecomment-1940793381 @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.

Re: [PR] [FLINK-34193][Connectors/Kafka] Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka [flink-connector-kafka]

2024-02-13 Thread via GitHub
MartijnVisser commented on PR #83: URL: https://github.com/apache/flink-connector-kafka/pull/83#issuecomment-1940778633 Superseded by https://github.com/apache/flink-connector-kafka/pull/84 -- This is an automated message from the Apache Git Service. To respond to the message, please log

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

2024-02-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34192. -- Fix Version/s: kafka-3.1.1 Resolution: Fixed Fixed in apache/flink-connector-kafka

Re: [PR] [FLINK-34193][Connectors/Kafka] Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka [flink-connector-kafka]

2024-02-13 Thread via GitHub
MartijnVisser closed pull request #83: [FLINK-34193][Connectors/Kafka] Remove usage of Flink-Shaded Jackson and Snakeyaml in flink-connector-kafka URL: https://github.com/apache/flink-connector-kafka/pull/83 -- This is an automated message from the Apache Git Service. To respond to the

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

2024-02-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser closed FLINK-34193. -- Fix Version/s: kafka-3.1.1 Assignee: jiabao.sun Resolution: Fixed Fixed in

Re: [PR] [BP][FLINK-34192][FLINK-34194] Update to be compatible with updated SinkV2 interfaces [flink-connector-kafka]

2024-02-13 Thread via GitHub
MartijnVisser merged PR #86: URL: https://github.com/apache/flink-connector-kafka/pull/86 -- 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] Bump org.yaml:snakeyaml from 1.31 to 2.0 [flink-connector-elasticsearch]

2024-02-13 Thread via GitHub
MartijnVisser commented on PR #90: URL: https://github.com/apache/flink-connector-elasticsearch/pull/90#issuecomment-1940775718 @snuyanzin I'm confused, I would have expected CI to fail since SnakeYAML requires JDK17; any idea why everything passed on JDK8 and JDK11? -- This is an

[jira] [Assigned] (FLINK-34432) Re-enable forkReuse for flink-table-planner

2024-02-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Martijn Visser reassigned FLINK-34432: -- Assignee: Martijn Visser > Re-enable forkReuse for flink-table-planner >

[jira] [Updated] (FLINK-34432) Re-enable forkReuse for flink-table-planner

2024-02-13 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34432: --- Labels: pull-request-available (was: ) > Re-enable forkReuse for flink-table-planner >

[jira] [Commented] (FLINK-18356) flink-table-planner Exit code 137 returned from process

2024-02-13 Thread Martijn Visser (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816899#comment-17816899 ] Martijn Visser commented on FLINK-18356: Filed https://issues.apache.org/jira/browse/FLINK-34432

Re: [PR] [FLINK-34432] Re-enable forkReuse for flink-table-planner [flink]

2024-02-13 Thread via GitHub
MartijnVisser commented on PR #24305: URL: https://github.com/apache/flink/pull/24305#issuecomment-1940730677 These are the CI runs: Personal CI Run 1: https://dev.azure.com/martijn0323/Flink/_build/results?buildId=4192=results ✅ Personal CI Run 2:

Re: [PR] Bump org.yaml:snakeyaml from 1.31 to 2.0 in /flink-connector-kafka [flink-connector-kafka]

2024-02-13 Thread via GitHub
MartijnVisser commented on PR #85: URL: https://github.com/apache/flink-connector-kafka/pull/85#issuecomment-1940719903 We can't do this version upgrade, since this requires Java 17 and we have to support lower versions as well (at this moment). Closing the PR. -- This is an automated

Re: [PR] Bump org.yaml:snakeyaml from 1.31 to 2.0 in /flink-connector-kafka [flink-connector-kafka]

2024-02-13 Thread via GitHub
dependabot[bot] commented on PR #85: URL: https://github.com/apache/flink-connector-kafka/pull/85#issuecomment-1940720010 OK, I won't notify you again about this release, but will get in touch when a new version is available. If you'd rather skip all updates until the next major or minor

Re: [PR] Bump org.yaml:snakeyaml from 1.31 to 2.0 in /flink-connector-kafka [flink-connector-kafka]

2024-02-13 Thread via GitHub
MartijnVisser closed pull request #85: Bump org.yaml:snakeyaml from 1.31 to 2.0 in /flink-connector-kafka URL: https://github.com/apache/flink-connector-kafka/pull/85 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

[jira] [Closed] (FLINK-34367) Release Testing Instructions: Verify FLINK-34027 AsyncScalarFunction for asynchronous scalar function support

2024-02-13 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge closed FLINK-34367. --- Resolution: Fixed > Release Testing Instructions: Verify FLINK-34027 AsyncScalarFunction for >

Re: [PR] [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode [flink]

2024-02-13 Thread via GitHub
ferenc-csaky commented on code in PR #24303: URL: https://github.com/apache/flink/pull/24303#discussion_r1487357451 ## flink-kubernetes/src/main/java/org/apache/flink/kubernetes/artifact/DefaultKubernetesArtifactUploader.java: ## @@ -0,0 +1,122 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-13 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1486986597 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -231,6 +232,21 @@ ANY,

Re: [PR] [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode [flink]

2024-02-13 Thread via GitHub
ferenc-csaky commented on code in PR #24303: URL: https://github.com/apache/flink/pull/24303#discussion_r1487369239 ## flink-clients/src/main/java/org/apache/flink/client/cli/ArtifactFetchOptionsInternal.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-13 Thread via GitHub
hanyuzheng7 commented on code in PR #22951: URL: https://github.com/apache/flink/pull/22951#discussion_r1486986597 ## flink-table/flink-table-common/src/main/java/org/apache/flink/table/functions/BuiltInFunctionDefinitions.java: ## @@ -231,6 +232,21 @@ ANY,

[jira] [Updated] (FLINK-34273) git fetch fails

2024-02-13 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-34273: Priority: Major (was: Critical) > git fetch fails > --- > > Key: FLINK-34273

[jira] [Assigned] (FLINK-34427) ResourceManagerTaskExecutorTest fails fatally (exit code 239)

2024-02-13 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-34427: --- Assignee: Matthias Pohl > ResourceManagerTaskExecutorTest fails fatally (exit code 239) >

[jira] [Assigned] (FLINK-34425) TaskManagerRunnerITCase#testNondeterministicWorkingDirIsDeletedInCaseOfProcessFailure times out

2024-02-13 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-34425: --- Assignee: Matthias Pohl >

[jira] [Created] (FLINK-34432) Re-enable forkReuse for flink-table-planner

2024-02-13 Thread Martijn Visser (Jira)
Martijn Visser created FLINK-34432: -- Summary: Re-enable forkReuse for flink-table-planner Key: FLINK-34432 URL: https://issues.apache.org/jira/browse/FLINK-34432 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-34404) GroupWindowAggregateProcTimeRestoreTest#testRestore times out

2024-02-13 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-34404: --- Assignee: Alan Sheinberg > GroupWindowAggregateProcTimeRestoreTest#testRestore times out >

Re: [PR] [FLINK-32315][k8s] Support uploading "local://" artifacts in Kubernetes Application Mode [flink]

2024-02-13 Thread via GitHub
ferenc-csaky commented on code in PR #24303: URL: https://github.com/apache/flink/pull/24303#discussion_r1487369239 ## flink-clients/src/main/java/org/apache/flink/client/cli/ArtifactFetchOptionsInternal.java: ## @@ -0,0 +1,36 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-26948][table] Add-ARRAY_SORT-function. [flink]

2024-02-13 Thread via GitHub
hanyuzheng7 commented on PR #22951: URL: https://github.com/apache/flink/pull/22951#issuecomment-1940657344 @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

<    1   2