[jira] [Commented] (FLINK-33449) Support array_contains_seq function

2023-12-14 Thread leo cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796606#comment-17796606 ] leo cheng commented on FLINK-33449: --- Hi [~xuyangzhong] Thank you for your reply ARRAY_CONTAINS_SEQ

[jira] [Commented] (FLINK-33082) Azure Pipelines 4 is not responding on AZP

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

[jira] [Resolved] (FLINK-33811) The CI for frocksdb has broken

2023-12-14 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33811?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-33811. - Resolution: Fixed > The CI for frocksdb has broken > -- > >

[jira] [Commented] (FLINK-33811) The CI for frocksdb has broken

2023-12-14 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33811?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796614#comment-17796614 ] Zakelly Lan commented on FLINK-33811: - Merged into FRocksDB-6.20.3 via

Re: [PR] [FLINK-33810][Runtime] Propagate RecordAttributes that contains isProcessingBacklog status [flink]

2023-12-14 Thread via GitHub
Sxnan commented on code in PR #23919: URL: https://github.com/apache/flink/pull/23919#discussion_r1426426138 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/RecordAttributesCombiner.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache Software

[jira] [Created] (FLINK-33820) StreamingWithStateTestBase's subclasses might fail during cleanup if sharing the state directory (through a common @TempDir)

2023-12-14 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33820: - Summary: StreamingWithStateTestBase's subclasses might fail during cleanup if sharing the state directory (through a common @TempDir) Key: FLINK-33820 URL:

Re: [PR] [FLINK-33808] Implement restore tests for WindowJoin node [flink]

2023-12-14 Thread via GitHub
dawidwys merged PR #23918: URL: https://github.com/apache/flink/pull/23918 -- 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-33641][test] Suppress the DirectoryNotEmptyException in StreamingWithStateTestBase to prevent test failures [flink]

2023-12-14 Thread via GitHub
XComp commented on PR #23914: URL: https://github.com/apache/flink/pull/23914#issuecomment-1855535740 Sounds reasonable. Can you create a follow-up ticket for that one? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-33754) Serialize QueryOperations into SQL

2023-12-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796685#comment-17796685 ] Dawid Wysakowicz commented on FLINK-33754: -- I overlooked this operation. Sorry, I will add

[jira] [Commented] (FLINK-33754) Serialize QueryOperations into SQL

2023-12-14 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796688#comment-17796688 ] Benchao Li commented on FLINK-33754: [~dwysakowicz] Looking forward to it :) > Serialize

Re: [PR] [FLINK-33588][Flink-Runtime] Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics [flink]

2023-12-14 Thread via GitHub
zhutong6688 closed pull request #23915: [FLINK-33588][Flink-Runtime] Fix NullArgumentException of getQuantile method in DescriptiveStatisticsHistogramStatistics URL: https://github.com/apache/flink/pull/23915 -- This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-33824) Prepare Flink 1.18.1 Release

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33824: Description: This umbrella issue is meant as a test balloon for moving the [release

Re: [PR] [FLINK-33822] Adds Slack invite URL parameter to config [flink-web]

2023-12-14 Thread via GitHub
XComp merged PR #704: URL: https://github.com/apache/flink-web/pull/704 -- 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-33603][FileSystems] shade guava in gs-fs filesystem [flink]

2023-12-14 Thread via GitHub
singhravidutt commented on PR #23489: URL: https://github.com/apache/flink/pull/23489#issuecomment-1855726357 @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-33641][test] Suppress the DirectoryNotEmptyException in StreamingWithStateTestBase to prevent test failures [flink]

2023-12-14 Thread via GitHub
XComp merged PR #23914: URL: https://github.com/apache/flink/pull/23914 -- 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-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-14 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1426516597 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java: ## @@ -127,7 +155,28 @@ public void

Re: [PR] [FLINK-33813][autoscaler] Improve time formatting for easier reading inside the autoscaler [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
1996fanrui merged PR #731: URL: https://github.com/apache/flink-kubernetes-operator/pull/731 -- 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] [Comment Edited] (FLINK-33754) Serialize QueryOperations into SQL

2023-12-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33754?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796685#comment-17796685 ] Dawid Wysakowicz edited comment on FLINK-33754 at 12/14/23 11:25 AM: -

[jira] [Created] (FLINK-33823) Serialize PlannerQueryOperation into SQL

2023-12-14 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-33823: Summary: Serialize PlannerQueryOperation into SQL Key: FLINK-33823 URL: https://issues.apache.org/jira/browse/FLINK-33823 Project: Flink Issue Type:

[jira] [Reopened] (FLINK-33644) FLIP-393: Make QueryOperations SQL serializable

2023-12-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz reopened FLINK-33644: -- > FLIP-393: Make QueryOperations SQL serializable >

[jira] [Created] (FLINK-33822) Move Slack Invite URL into config.toml

2023-12-14 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-33822: - Summary: Move Slack Invite URL into config.toml Key: FLINK-33822 URL: https://issues.apache.org/jira/browse/FLINK-33822 Project: Flink Issue Type: Bug

Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink]

2023-12-14 Thread via GitHub
XComp commented on code in PR #23880: URL: https://github.com/apache/flink/pull/23880#discussion_r1426546494 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobGraphWriter.java: ## @@ -37,6 +38,18 @@ public interface JobGraphWriter extends

Re: [PR] [FLINK-33770] Migrate legacy autoscaler config keys [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
mxm commented on code in PR #729: URL: https://github.com/apache/flink-kubernetes-operator/pull/729#discussion_r1426558636 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java: ## @@ -247,21 +222,41 @@ private static

Re: [PR] [FLINK-33764] Track Heap usage and GC pressure to avoid unnecessary scaling [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
gyfora commented on PR #726: URL: https://github.com/apache/flink-kubernetes-operator/pull/726#issuecomment-1855635579 Fair point @mxm , I will adjust the limits to effectively disable the blocking by default. And we can build some more robust mechanisms on top of these collected TM level

Re: [PR] [FLINK-33770] Migrate legacy autoscaler config keys [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
mxm commented on code in PR #729: URL: https://github.com/apache/flink-kubernetes-operator/pull/729#discussion_r1426558636 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java: ## @@ -247,21 +222,41 @@ private static

[jira] [Assigned] (FLINK-30535) Introduce TTL state based benchmarks

2023-12-14 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-30535: --- Assignee: Zakelly Lan > Introduce TTL state based benchmarks >

[jira] [Assigned] (FLINK-33825) CLONE - Create a new version in JIRA

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-33825: --- Assignee: (was: Martijn Visser) > CLONE - Create a new version in JIRA >

[jira] [Created] (FLINK-33827) CLONE - Review and update documentation

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33827: --- Summary: CLONE - Review and update documentation Key: FLINK-33827 URL: https://issues.apache.org/jira/browse/FLINK-33827 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-33641) JUnit5 fails to delete a directory on AZP for various table-planner tests

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

Re: [PR] [FLINK-33641][test] Suppress the DirectoryNotEmptyException in StreamingWithStateTestBase to prevent test failures [flink]

2023-12-14 Thread via GitHub
Jiabao-Sun commented on PR #23914: URL: https://github.com/apache/flink/pull/23914#issuecomment-1855510460 Thanks @XComp, the ArchUnit's rules require the `MiniclusteExtension` declared as `static final`, but in scala, we can only declare it `private val` in `object`, but this cannot be

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-14 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1426543430 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java: ## @@ -127,7 +155,28 @@ public void

Re: [PR] [FLINK-33632] Adding custom flink mutator [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
tagarr commented on PR #733: URL: https://github.com/apache/flink-kubernetes-operator/pull/733#issuecomment-1855602604 Looks good. My only question would be to the committers. 1. Would we like the sessionjob changes (i.e. modify labels) be done in

Re: [PR] [FLINK-33795] Add new config to forbid autoscaling in certain periods of a day [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
mxm commented on code in PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1426564377 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java: ## @@ -72,6 +72,15 @@ private static

[jira] [Commented] (FLINK-33502) HybridShuffleITCase caused a fatal error

2023-12-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796617#comment-17796617 ] Matthias Pohl commented on FLINK-33502: --- Another GHA workflow failure:

Re: [PR] [FLINK-33536] Fix Flink Table API CSV streaming sink fails with IOException: Stream closed [flink]

2023-12-14 Thread via GitHub
Samrat002 commented on PR #23725: URL: https://github.com/apache/flink/pull/23725#issuecomment-1855489106 @MartijnVisser please review whenever time -- 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

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-14 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1426510597 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java: ## @@ -127,7 +155,28 @@ public void

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-14 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1426523374 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridge.java: ## @@ -200,10 +226,45 @@ protected void

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-14 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1426524511 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridge.java: ## @@ -200,10 +226,45 @@ protected void

Re: [PR] [FLINK-20772][State] Make TtlValueState#update follow the description of interface about null values [flink]

2023-12-14 Thread via GitHub
Zakelly commented on PR #23928: URL: https://github.com/apache/flink/pull/23928#issuecomment-1855583922 @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-33764] Track Heap usage and GC pressure to avoid unnecessary scaling [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
mxm commented on PR #726: URL: https://github.com/apache/flink-kubernetes-operator/pull/726#issuecomment-1855592264 >However I am personally very much in favour of enabling it at least for the GC time for the following reason: >When you spend a considerable time in GC (30% is

[jira] [Resolved] (FLINK-33813) Improve time formatting for easier reading inside the autoscaler

2023-12-14 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33813. - Resolution: Fixed > Improve time formatting for easier reading inside the autoscaler >

[jira] [Created] (FLINK-33830) CLONE - Select executing Release Manager

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33830: --- Summary: CLONE - Select executing Release Manager Key: FLINK-33830 URL: https://issues.apache.org/jira/browse/FLINK-33830 Project: Flink Issue Type: Sub-task

[jira] [Assigned] (FLINK-33826) CLONE - Triage release-blocking issues in JIRA

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-33826: --- Assignee: Jing Ge (was: Qingsheng Ren) > CLONE - Triage release-blocking issues in JIRA >

[PR] [FLINK-33822] Adds Slack invite URL parameter to config [flink-web]

2023-12-14 Thread via GitHub
XComp opened a new pull request, #704: URL: https://github.com/apache/flink-web/pull/704 Additionally, I updated the URL to cover the [request the dev ML](https://lists.apache.org/thread/g7c6m02zv8m1rznowy914p0jmy2b09j3) -- This is an automated message from the Apache Git Service. To

Re: [PR] [hotfix] Apply spotless [flink]

2023-12-14 Thread via GitHub
XComp merged PR #23929: URL: https://github.com/apache/flink/pull/23929 -- 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] [Created] (FLINK-33824) Prepare Flink 1.18.1 Release

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33824: --- Summary: Prepare Flink 1.18.1 Release Key: FLINK-33824 URL: https://issues.apache.org/jira/browse/FLINK-33824 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-33826) CLONE - Triage release-blocking issues in JIRA

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33826: --- Summary: CLONE - Triage release-blocking issues in JIRA Key: FLINK-33826 URL: https://issues.apache.org/jira/browse/FLINK-33826 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33829) CLONE - Review Release Notes in JIRA

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33829: --- Summary: CLONE - Review Release Notes in JIRA Key: FLINK-33829 URL: https://issues.apache.org/jira/browse/FLINK-33829 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33825) CLONE - Create a new version in JIRA

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33825: --- Summary: CLONE - Create a new version in JIRA Key: FLINK-33825 URL: https://issues.apache.org/jira/browse/FLINK-33825 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-33822) Move Slack Invite URL into config.toml

2023-12-14 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33822: --- Labels: pull-request-available (was: ) > Move Slack Invite URL into config.toml >

[PR] [FLINK-33770] Silence Configuration logging for INFO messages [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
mxm opened a new pull request, #734: URL: https://github.com/apache/flink-kubernetes-operator/pull/734 In #725 we coverted the deprecated keys fallback keys and added test coverage. This additional change silences logs for fallback keys by setting the configuration logging to WARN instead

Re: [PR] [FLINK-33770] Migrate legacy autoscaler config keys [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
mxm commented on PR #729: URL: https://github.com/apache/flink-kubernetes-operator/pull/729#issuecomment-1855734056 While testing, I noticed that the abstraction in the PR doesn't fully hold because there is code in the reconciler which access autoscaler options and uses the observe

Re: [PR] [FLINK-33770] Migrate legacy autoscaler config keys [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
mxm closed pull request #729: [FLINK-33770] Migrate legacy autoscaler config keys URL: https://github.com/apache/flink-kubernetes-operator/pull/729 -- 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

[jira] [Commented] (FLINK-18476) PythonEnvUtilsTest#testStartPythonProcess fails

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

Re: [PR] [FLINK-33500][Runtime] Run storing the JobGraph an asynchronous operation [flink]

2023-12-14 Thread via GitHub
XComp commented on code in PR #23880: URL: https://github.com/apache/flink/pull/23880#discussion_r1426546494 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmanager/JobGraphWriter.java: ## @@ -37,6 +38,18 @@ public interface JobGraphWriter extends

Re: [PR] [hotfix] Apply spotless [flink]

2023-12-14 Thread via GitHub
XComp commented on PR #23929: URL: https://github.com/apache/flink/pull/23929#issuecomment-1855624116 > Uh, thanks. That's odd. Why didn't it pop up in the CI of the https://github.com/apache/flink/pull/23914#issuecomment-1852331226. 樂 Ah, I double-checked. My commit

Re: [PR] [FLINK-32993][table] Datagen connector handles length-constrained fields according to the schema definition by default [flink]

2023-12-14 Thread via GitHub
liyubin117 commented on PR #23678: URL: https://github.com/apache/flink/pull/23678#issuecomment-1855638485 @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-33764] Track Heap usage and GC pressure to avoid unnecessary scaling [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
1996fanrui commented on code in PR #726: URL: https://github.com/apache/flink-kubernetes-operator/pull/726#discussion_r1426576655 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java: ## @@ -219,6 +219,22 @@ private static

[jira] [Assigned] (FLINK-33824) Prepare Flink 1.18.1 Release

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge reassigned FLINK-33824: --- Assignee: Jing Ge (was: Leonard Xu) > Prepare Flink 1.18.1 Release >

[jira] [Updated] (FLINK-33824) Prepare Flink 1.18.1 Release

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33824: Affects Version/s: 1.18.0 (was: 1.17.0) > Prepare Flink 1.18.1 Release >

[jira] [Updated] (FLINK-33824) Prepare Flink 1.18.1 Release

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33824: Fix Version/s: 1.18.1 (was: 1.17.0) > Prepare Flink 1.18.1 Release >

[jira] [Created] (FLINK-33828) CLONE - Cross team testing

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33828: --- Summary: CLONE - Cross team testing Key: FLINK-33828 URL: https://issues.apache.org/jira/browse/FLINK-33828 Project: Flink Issue Type: Sub-task Reporter:

[jira] [Created] (FLINK-33831) CLONE - Create a release branch

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33831: --- Summary: CLONE - Create a release branch Key: FLINK-33831 URL: https://issues.apache.org/jira/browse/FLINK-33831 Project: Flink Issue Type: Sub-task Affects

[jira] [Created] (FLINK-33832) CLONE - Verify that no exclusions were erroneously added to the japicmp plugin

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33832: --- Summary: CLONE - Verify that no exclusions were erroneously added to the japicmp plugin Key: FLINK-33832 URL: https://issues.apache.org/jira/browse/FLINK-33832 Project: Flink

[jira] [Commented] (FLINK-32573) Translate "Custom Serialization for Managed State" page into Chinese

2023-12-14 Thread Jinsui Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17796700#comment-17796700 ] Jinsui Chen commented on FLINK-32573: - hi, [~jark] . Would you please assign this to me? >

[jira] [Resolved] (FLINK-33641) JUnit5 fails to delete a directory on AZP for various table-planner tests

2023-12-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-33641. --- Fix Version/s: 1.19.0 Assignee: Jiabao Sun Resolution: Fixed master:

[jira] [Created] (FLINK-33821) ArrowSerializer$finishCurrentBatch consumes too much time

2023-12-14 Thread wuwenchi (Jira)
wuwenchi created FLINK-33821: Summary: ArrowSerializer$finishCurrentBatch consumes too much time Key: FLINK-33821 URL: https://issues.apache.org/jira/browse/FLINK-33821 Project: Flink Issue

[jira] [Closed] (FLINK-33808) Implement restore tests for WindowJoin node

2023-12-14 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-33808. Fix Version/s: 1.19.0 Resolution: Implemented Implemented in

Re: [PR] [FLINK-33386][runtime] Support tasks balancing at slot level for Default Scheduler [flink]

2023-12-14 Thread via GitHub
RocMarshal commented on code in PR #23635: URL: https://github.com/apache/flink/pull/23635#discussion_r1426543430 ## flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/DefaultDeclarativeSlotPool.java: ## @@ -127,7 +155,28 @@ public void

Re: [PR] [FLINK-33632] Adding custom flink mutator [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
tagarr commented on PR #733: URL: https://github.com/apache/flink-kubernetes-operator/pull/733#issuecomment-1855604122 @gyfora would love your opinion on this... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [FLINK-33641][test] Suppress the DirectoryNotEmptyException in StreamingWithStateTestBase to prevent test failures [flink]

2023-12-14 Thread via GitHub
snuyanzin commented on PR #23914: URL: https://github.com/apache/flink/pull/23914#issuecomment-1855611405 @XComp , @Jiabao-Sun it seems current build failure is related could you please have a look https://github.com/apache/flink/pull/23929 -- This is an automated message from

[jira] [Resolved] (FLINK-33822) Move Slack Invite URL into config.toml

2023-12-14 Thread Matthias Pohl (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias Pohl resolved FLINK-33822. --- Assignee: Matthias Pohl Resolution: Fixed asf-site:

Re: [PR] [FLINK-33764] Track Heap usage and GC pressure to avoid unnecessary scaling [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
1996fanrui commented on code in PR #726: URL: https://github.com/apache/flink-kubernetes-operator/pull/726#discussion_r1426689038 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/MetricsCollectionAndEvaluationTest.java: ## @@ -188,6 +187,13 @@ public void

Re: [PR] [FLINK-20772][State] Make TtlValueState#update follow the description of interface about null values [flink]

2023-12-14 Thread via GitHub
Zakelly commented on PR #23928: URL: https://github.com/apache/flink/pull/23928#issuecomment-1855894096 @masteryhx Would you please to take a look? Thanks -- 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

Re: [PR] [FLINK-33795] Add new config to forbid autoscaling in certain periods of a day [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
flashJd commented on code in PR #728: URL: https://github.com/apache/flink-kubernetes-operator/pull/728#discussion_r1426748818 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/JobAutoScalerImpl.java: ## @@ -96,6 +97,13 @@ public void scale(Context ctx) throws

[PR] [hotfix] Test connector against Flink 1.16.2, 1.17.1, 1.18.0 instead of Flink SNAPSHOT version [flink-connector-mongodb]

2023-12-14 Thread via GitHub
ruanhang1993 opened a new pull request, #20: URL: https://github.com/apache/flink-connector-mongodb/pull/20 This PR change the ci to use the release version 1.16.2, 1.17.1, 1.18.0 instead of Flink SNAPSHOT version. -- This is an automated message from the Apache Git Service. To respond

Re: [PR] [hotfix] Test connector against Flink 1.16.2, 1.17.1, 1.18.0 instead of Flink SNAPSHOT version [flink-connector-mongodb]

2023-12-14 Thread via GitHub
boring-cyborg[bot] commented on PR #20: URL: https://github.com/apache/flink-connector-mongodb/pull/20#issuecomment-1855933326 Thanks for opening this pull request! Please check out our contributing guidelines. (https://flink.apache.org/contributing/how-to-contribute.html) -- This

[jira] [Updated] (FLINK-33828) No need - Cross team testing

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33828: Summary: No need - Cross team testing (was: CLONE - Cross team testing) > No need - Cross team testing >

[jira] [Closed] (FLINK-33828) No need - Cross team testing

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge closed FLINK-33828. --- Assignee: Jing Ge (was: Qingsheng Ren) Resolution: Won't Fix > No need - Cross team testing >

[jira] [Updated] (FLINK-33829) CLONE - Review Release Notes in JIRA

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33829: Description: Example for patch release: 

[jira] [Created] (FLINK-33838) Finalize release 1.18.1

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33838: --- Summary: Finalize release 1.18.1 Key: FLINK-33838 URL: https://issues.apache.org/jira/browse/FLINK-33838 Project: Flink Issue Type: New Feature Affects Versions:

[jira] [Created] (FLINK-33839) CLONE - Deploy Python artifacts to PyPI

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33839: --- Summary: CLONE - Deploy Python artifacts to PyPI Key: FLINK-33839 URL: https://issues.apache.org/jira/browse/FLINK-33839 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-33841) CLONE - Create Git tag and mark version as released in Jira

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33841: --- Summary: CLONE - Create Git tag and mark version as released in Jira Key: FLINK-33841 URL: https://issues.apache.org/jira/browse/FLINK-33841 Project: Flink Issue

[jira] [Updated] (FLINK-33824) Prepare Flink 1.18.1 Release

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33824: Fix Version/s: (was: 1.18.1) > Prepare Flink 1.18.1 Release > > >

[jira] [Updated] (FLINK-33833) Build Release Candidate: 1.18.1-rc1

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33833: Fix Version/s: (was: 1.18.1) > Build Release Candidate: 1.18.1-rc1 >

[jira] [Updated] (FLINK-33836) Propose a pull request for website updates

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33836: Fix Version/s: (was: 1.18.1) > Propose a pull request for website updates >

[jira] [Updated] (FLINK-33831) Checkout the release branch

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33831?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33831: Fix Version/s: (was: 1.18.1) > Checkout the release branch > --- > >

[jira] [Created] (FLINK-33849) CLONE - Update reference data for Migration Tests

2023-12-14 Thread Jing Ge (Jira)
Jing Ge created FLINK-33849: --- Summary: CLONE - Update reference data for Migration Tests Key: FLINK-33849 URL: https://issues.apache.org/jira/browse/FLINK-33849 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-33844) Update japicmp configuration

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33844: Fix Version/s: (was: 1.18.1) > Update japicmp configuration > > >

[jira] [Updated] (FLINK-33845) Merge website pull request

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33845: Summary: Merge website pull request (was: CLONE - Merge website pull request) > Merge website pull

[jira] [Updated] (FLINK-33847) Apache mailing lists announcements

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33847: Summary: Apache mailing lists announcements (was: CLONE - Apache mailing lists announcements) > Apache

[jira] [Updated] (FLINK-33844) Update japicmp configuration

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33844: Fix Version/s: (was: 1.19.0) > Update japicmp configuration > > >

[jira] [Updated] (FLINK-33846) Remove outdated versions

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33846?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33846: Summary: Remove outdated versions (was: CLONE - Remove outdated versions) > Remove outdated versions >

[jira] [Updated] (FLINK-33829) Review Release Notes in JIRA

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33829: Description: https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522=12353640 (was:

[jira] [Resolved] (FLINK-33830) Select executing Release Manager

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge resolved FLINK-33830. - Fix Version/s: (was: 1.17.0) Resolution: Fixed > Select executing Release Manager >

[jira] [Updated] (FLINK-33830) Select executing Release Manager

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33830?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33830: Affects Version/s: 1.18.0 (was: 1.17.0) > Select executing Release Manager >

[jira] [Updated] (FLINK-33827) Review and update documentation

2023-12-14 Thread Jing Ge (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jing Ge updated FLINK-33827: Description: (was: There are a few pages in the documentation that need to be reviewed and updated

Re: [PR] [FLINK-33764] Track Heap usage and GC pressure to avoid unnecessary scaling [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
gyfora commented on code in PR #726: URL: https://github.com/apache/flink-kubernetes-operator/pull/726#discussion_r1426670350 ## flink-autoscaler/src/test/java/org/apache/flink/autoscaler/MetricsCollectionAndEvaluationTest.java: ## @@ -188,6 +187,13 @@ public void

Re: [PR] [FLINK-33764] Track Heap usage and GC pressure to avoid unnecessary scaling [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
gyfora commented on code in PR #726: URL: https://github.com/apache/flink-kubernetes-operator/pull/726#discussion_r1426669381 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/config/AutoScalerOptions.java: ## @@ -219,6 +219,22 @@ private static

Re: [PR] [FLINK-33632] Adding custom flink mutator [flink-kubernetes-operator]

2023-12-14 Thread via GitHub
gyfora commented on PR #733: URL: https://github.com/apache/flink-kubernetes-operator/pull/733#issuecomment-1855787058 ``` Brief change log No change in logs ``` This section should ideally be filled out with the list of changes that were made to implement the given

  1   2   3   >