[jira] [Commented] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

2024-02-18 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818325#comment-17818325 ] Yangze Guo commented on FLINK-34434: Good catch [~mapohl]. I think the returnedFuture should be

[jira] [Assigned] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

2024-02-18 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo reassigned FLINK-34434: -- Assignee: Yangze Guo > DefaultSlotStatusSyncer doesn't complete the returned future >

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-18 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818326#comment-17818326 ] Dian Fu commented on FLINK-34202: - [~lincoln.86xy] It will randomly select one Python version to test

[jira] [Updated] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

2024-02-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34434: --- Labels: pull-request-available (was: ) > DefaultSlotStatusSyncer doesn't complete the

[PR] [FLINK-34434][slotmanager] Complete the returnedFuture when slot remo… [flink]

2024-02-18 Thread via GitHub
KarmaGYZ opened a new pull request, #24325: URL: https://github.com/apache/flink/pull/24325 …ved before allocation success ## What is the purpose of the change To fix the typo in DefaultSlotStatusSyncer. ## Brief change log Complete the returnedFuture,

Re: [PR] [CP-1.18][FLINK-34434][slotmanager] Complete the returnedFuture when slot remo… [flink]

2024-02-18 Thread via GitHub
flinkbot commented on PR #24327: URL: https://github.com/apache/flink/pull/24327#issuecomment-1951615473 ## CI report: * 463196de2af7f16fdb8742e240bf270c4c207bb9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-25015) job name should not always be `collect` submitted by sql client

2024-02-18 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818334#comment-17818334 ] Yangze Guo commented on FLINK-25015: master: dcb30f934a7953e33d35460414c6ee57cb982ab3 > job name

Re: [PR] [FLINK-25015][Table SQL] Use SQL string as jobName for DQL jobs submitted by sql-gateway [flink]

2024-02-18 Thread via GitHub
KarmaGYZ commented on PR #23455: URL: https://github.com/apache/flink/pull/23455#issuecomment-1951630056 LGTM -- 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

Re: [PR] [FLINK-25015][Table SQL] Use SQL string as jobName for DQL jobs submitted by sql-gateway [flink]

2024-02-18 Thread via GitHub
KarmaGYZ merged PR #23455: URL: https://github.com/apache/flink/pull/23455 -- 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-34358] Fix some tests that failed in Flink 1.19 [flink-connector-jdbc]

2024-02-18 Thread via GitHub
wanglijie95 commented on PR #101: URL: https://github.com/apache/flink-connector-jdbc/pull/101#issuecomment-1951766110 @MartijnVisser Would you help review this pr? Thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[jira] [Commented] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-02-18 Thread junzhong qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818353#comment-17818353 ] junzhong qin commented on FLINK-34261: -- Close this issue because TaskExecutorManager has been

[jira] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-02-18 Thread junzhong qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34261 ] junzhong qin deleted comment on FLINK-34261: -- was (Author: easonqin): Close this issue because TaskExecutorManager has been removed from the master branch. > When

[jira] [Closed] (FLINK-34261) When slotmanager.redundant-taskmanager-num is set to a value greater than 1, redundant task managers may be repeatedly released and requested

2024-02-18 Thread junzhong qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] junzhong qin closed FLINK-34261. Resolution: Fixed Close this issue because TaskExecutorManager has been removed from the master

[jira] [Assigned] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order

2024-02-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26050: - Assignee: Roman Khachatryan > Too many small sst files in rocksdb state

Re: [PR] [CP-1.19][FLINK-34434][slotmanager] Complete the returnedFuture when slot remo… [flink]

2024-02-18 Thread via GitHub
flinkbot commented on PR #24326: URL: https://github.com/apache/flink/pull/24326#issuecomment-1951611530 ## CI report: * 2a689d891e8b40e4caf4df96d6beffa114d0651e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [Draft][bugfix] Move the deserialization of shuffleDescriptor to a separate … [flink]

2024-02-18 Thread via GitHub
caodizhou commented on PR #24115: URL: https://github.com/apache/flink/pull/24115#issuecomment-1951668636 @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] [Created] (FLINK-34460) Jdbc driver get rid of flink-core

2024-02-18 Thread Fang Yong (Jira)
Fang Yong created FLINK-34460: - Summary: Jdbc driver get rid of flink-core Key: FLINK-34460 URL: https://issues.apache.org/jira/browse/FLINK-34460 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-18 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818318#comment-17818318 ] lincoln lee commented on FLINK-34202: - [~hxb] Thanks for investigating this issue! Regarding the

[jira] [Comment Edited] (FLINK-34434) DefaultSlotStatusSyncer doesn't complete the returned future

2024-02-18 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818325#comment-17818325 ] Yangze Guo edited comment on FLINK-34434 at 2/19/24 2:33 AM: - Good catch

Re: [PR] [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption [flink]

2024-02-18 Thread via GitHub
Zakelly commented on PR #24181: URL: https://github.com/apache/flink/pull/24181#issuecomment-1951593556 @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.

[PR] [CP-1.18][FLINK-34434][slotmanager] Complete the returnedFuture when slot remo… [flink]

2024-02-18 Thread via GitHub
KarmaGYZ opened a new pull request, #24327: URL: https://github.com/apache/flink/pull/24327 …ved before allocation success Cherry pick FLINK-34434 to release-1.18 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Updated] (FLINK-25015) job name should not always be `collect` submitted by sql client

2024-02-18 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo updated FLINK-25015: --- Fix Version/s: 1.20.0 > job name should not always be `collect` submitted by sql client >

[jira] [Resolved] (FLINK-25015) job name should not always be `collect` submitted by sql client

2024-02-18 Thread Yangze Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yangze Guo resolved FLINK-25015. Resolution: Fixed > job name should not always be `collect` submitted by sql client >

[PR] [CP-1.19][FLINK-34434][slotmanager] Complete the returnedFuture when slot remo… [flink]

2024-02-18 Thread via GitHub
KarmaGYZ opened a new pull request, #24326: URL: https://github.com/apache/flink/pull/24326 …ved before allocation success Cherry pick FLINK-34434 to release-1.19 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Assigned] (FLINK-34358) flink-connector-jdbc nightly fails with "Expecting code to raise a throwable"

2024-02-18 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lijie Wang reassigned FLINK-34358: -- Assignee: Lijie Wang > flink-connector-jdbc nightly fails with "Expecting code to raise a

[jira] [Updated] (FLINK-34358) flink-connector-jdbc nightly fails with "Expecting code to raise a throwable"

2024-02-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34358: --- Labels: pull-request-available test-stability (was: test-stability) > flink-connector-jdbc

[jira] [Comment Edited] (FLINK-34358) flink-connector-jdbc nightly fails with "Expecting code to raise a throwable"

2024-02-18 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818346#comment-17818346 ] Lijie Wang edited comment on FLINK-34358 at 2/19/24 6:15 AM: - The test

Re: [PR] [FLINK-30081][runtime] Reset jvm-overhead.min/max for local executor [flink]

2024-02-18 Thread via GitHub
xintongsong commented on code in PR #22547: URL: https://github.com/apache/flink/pull/22547#discussion_r1493924976 ## flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutorResourceUtils.java: ## @@ -285,4 +286,15 @@ private static void

Re: [PR] [FLINK-34434][slotmanager] Complete the returnedFuture when slot remo… [flink]

2024-02-18 Thread via GitHub
flinkbot commented on PR #24325: URL: https://github.com/apache/flink/pull/24325#issuecomment-1951607706 ## CI report: * ea75f2c6dedfdebef152e55eb0313a4489f4338e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34358] Fix some tests that failed in Flink 1.19 [flink-connector-jdbc]

2024-02-18 Thread via GitHub
wanglijie95 opened a new pull request, #101: URL: https://github.com/apache/flink-connector-jdbc/pull/101 Fix some tests that failed in Flink 1.19, see FLINK-34358 for detailsn -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[jira] [Assigned] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

2024-02-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-30081: Assignee: Mingliang Liu > Local executor can not accept different jvm-overhead.min/max

[jira] [Updated] (FLINK-30081) Local executor can not accept different jvm-overhead.min/max values

2024-02-18 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-30081: - Priority: Major (was: Minor) > Local executor can not accept different jvm-overhead.min/max

[jira] [Updated] (FLINK-34453) [Benchmark] Add warmup in SchedulerBenchmarkExecutor

2024-02-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34453: --- Labels: pull-request-available (was: ) > [Benchmark] Add warmup in

Re: [PR] [FLINK-34453] Add warmup in SchedulerBenchmarkExecutorBase [flink-benchmarks]

2024-02-18 Thread via GitHub
fredia commented on code in PR #88: URL: https://github.com/apache/flink-benchmarks/pull/88#discussion_r1493945319 ## src/main/java/org/apache/flink/scheduler/benchmark/SchedulerBenchmarkExecutorBase.java: ## @@ -37,6 +38,7 @@ @State(Scope.Thread)

Re: [PR] [FLINK-34453] Add warmup in SchedulerBenchmarkExecutorBase [flink-benchmarks]

2024-02-18 Thread via GitHub
Zakelly closed pull request #88: [FLINK-34453] Add warmup in SchedulerBenchmarkExecutorBase URL: https://github.com/apache/flink-benchmarks/pull/88 -- 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

Re: [PR] [FLINK-34453] Add warmup in SchedulerBenchmarkExecutorBase [flink-benchmarks]

2024-02-18 Thread via GitHub
Zakelly commented on PR #88: URL: https://github.com/apache/flink-benchmarks/pull/88#issuecomment-1951646225 I had a discussion with Zhuzhu and found that the scheduler benchmarks is aim to measure the code start time. So no warmup should be added. I'm closing this. -- This is an

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-18 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818345#comment-17818345 ] lincoln lee commented on FLINK-34202: - [~dianfu] Yes, the difference is between testing 4 versions

[jira] [Commented] (FLINK-34358) flink-connector-jdbc nightly fails with "Expecting code to raise a throwable"

2024-02-18 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818346#comment-17818346 ] Lijie Wang commented on FLINK-34358: The test passes in flink 1.18 but fails in flink 1.19. The root

[jira] [Commented] (FLINK-34358) flink-connector-jdbc nightly fails with "Expecting code to raise a throwable"

2024-02-18 Thread Lijie Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818347#comment-17818347 ] Lijie Wang commented on FLINK-34358: The exception stack in 1.18: {code:java}

Re: [PR] [FLINK-33728] Do not rewatch when KubernetesResourceManagerDriver wat… [flink]

2024-02-18 Thread via GitHub
xintongsong commented on code in PR #24163: URL: https://github.com/apache/flink/pull/24163#discussion_r1494040971 ## flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java: ## @@ -412,11 +415,9 @@ private void stopPod(String podName) {

Re: [PR] [FLINK-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-02-18 Thread via GitHub
hejufang commented on PR #24322: URL: https://github.com/apache/flink/pull/24322#issuecomment-1951826026 @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] [Commented] (FLINK-34274) AdaptiveSchedulerTest.testRequirementLowerBoundDecreaseAfterResourceScarcityBelowAvailableSlots times out

2024-02-18 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818362#comment-17818362 ] lincoln lee commented on FLINK-34274: - 1.19:

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

2024-02-18 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818361#comment-17818361 ] lincoln lee commented on FLINK-32006: - master:

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-18 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818364#comment-17818364 ] lincoln lee commented on FLINK-34202: - 1.20(master):

Re: [PR] [FLINK-34458][checkpointing] Rename options for Generalized incremental checkpoints (changelog) [flink]

2024-02-18 Thread via GitHub
flinkbot commented on PR #24324: URL: https://github.com/apache/flink/pull/24324#issuecomment-1951136417 ## CI report: * 730574e51108e72c2e53ff119cf8dc71a65a05b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Commented] (FLINK-34400) Kafka sources with watermark alignment sporadically stop consuming

2024-02-18 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818280#comment-17818280 ] Rui Fan commented on FLINK-34400: - Hi [~asardaes] , did you try enable idleness? I try watermark

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

2024-02-18 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818283#comment-17818283 ] Feifan Wang commented on FLINK-33734: - [~roman] : {quote}Do I understand correctly, that the

[jira] [Updated] (FLINK-34452) Release Testing: Verify FLINK-15959 Add min number of slots configuration to limit total number of slots

2024-02-18 Thread xiangyu feng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiangyu feng updated FLINK-34452: - Description: Test Suggestion: # Prepare configuration options: **

[jira] [Updated] (FLINK-33734) Merge unaligned checkpoint state handle

2024-02-18 Thread Feifan Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Feifan Wang updated FLINK-33734: Attachment: flamegraph.control-group.html

[jira] [Created] (FLINK-34456) Move all checkpoint-related options into CheckpointingOptions

2024-02-18 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34456: --- Summary: Move all checkpoint-related options into CheckpointingOptions Key: FLINK-34456 URL: https://issues.apache.org/jira/browse/FLINK-34456 Project: Flink

Re: [PR] [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption [flink]

2024-02-18 Thread via GitHub
Zakelly commented on PR #24181: URL: https://github.com/apache/flink/pull/24181#issuecomment-1951061993 @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] [Commented] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

2024-02-18 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818266#comment-17818266 ] Rui Fan commented on FLINK-34252: - Thanks [~dchristle] for the report and fix, and thanks

[jira] [Updated] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

2024-02-18 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-34252: Fix Version/s: 1.19.0 1.18.2 1.20.0 > WatermarkAssignerOperator

[jira] [Comment Edited] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

2024-02-18 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818266#comment-17818266 ] Rui Fan edited comment on FLINK-34252 at 2/18/24 10:13 AM: --- Sorry for the late

Re: [PR] [FLINK-34457] Rename options for latency tracking [flink]

2024-02-18 Thread via GitHub
flinkbot commented on PR #24323: URL: https://github.com/apache/flink/pull/24323#issuecomment-1951078851 ## CI report: * 5b571eff191353c112f86f2c4b217ff982f7f75f UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34202: --- Labels: pull-request-available test-stability (was: test-stability) > python tests take

Re: [PR] [FLINK-34202][python] Optimize Python nightly CI time [flink]

2024-02-18 Thread via GitHub
HuangXingBo commented on PR #24321: URL: https://github.com/apache/flink/pull/24321#issuecomment-1951115536 https://dev.azure.com/hxbks2ks/FLINK-TEST/_build/results?buildId=2219=logs=fba17979-6d2e-591d-72f1-97cf42797c11=727942b6-6137-54f7-1ef9-e66e706ea068 - random select python 3.10

[jira] [Updated] (FLINK-34458) Rename options for Generalized incremental checkpoints (changelog)

2024-02-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34458: --- Labels: pull-request-available (was: ) > Rename options for Generalized incremental

[PR] [FLINK-34458][checkpointing] Rename options for Generalized incremental checkpoints (changelog) [flink]

2024-02-18 Thread via GitHub
Zakelly opened a new pull request, #24324: URL: https://github.com/apache/flink/pull/24324 ## What is the purpose of the change As one part of FLIP-406, this PR relocate the options for changelog under the prefix `state.changelog`. ## Brief change log - Rename the

[jira] [Commented] (FLINK-34202) python tests take suspiciously long in some of the cases

2024-02-18 Thread Xingbo Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818269#comment-17818269 ] Xingbo Huang commented on FLINK-34202: -- I reviewed all the stages where timeouts occurred and found

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

2024-02-18 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818251#comment-17818251 ] Roman Khachatryan commented on FLINK-33734: --- As for {quote}IIUC, ByteStreamStateHandle in each

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

2024-02-18 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818255#comment-17818255 ] Zakelly Lan commented on FLINK-33734: - [~Feifan Wang] Sorry for the late reply as I was on vacation

[jira] [Created] (FLINK-34458) Rename options for Generalized incremental checkpoints (changelog)

2024-02-18 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34458: --- Summary: Rename options for Generalized incremental checkpoints (changelog) Key: FLINK-34458 URL: https://issues.apache.org/jira/browse/FLINK-34458 Project: Flink

Re: [PR] [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption [flink]

2024-02-18 Thread via GitHub
Zakelly commented on PR #24181: URL: https://github.com/apache/flink/pull/24181#issuecomment-1951057156 The CI failure is not related with this PR since I only add comments based on last CI green. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Updated] (FLINK-34455) Move RestoreMode from flink-runtime to flink-core

2024-02-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34455: --- Labels: pull-request-available (was: ) > Move RestoreMode from flink-runtime to flink-core

Re: [PR] [FLINK-34455] Move RestoreMode from flink-runtime to flink-core [flink]

2024-02-18 Thread via GitHub
Zakelly commented on PR #24320: URL: https://github.com/apache/flink/pull/24320#issuecomment-1951058432 @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.

[PR] [FLINK-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-02-18 Thread via GitHub
hejufang opened a new pull request, #24322: URL: https://github.com/apache/flink/pull/24322 ## What is the purpose of the change Add sub-task level RocksDB file count metrics. ## Brief change log Get RocksDB file count of each level via RocksDB Property, and

[jira] [Updated] (FLINK-34334) Add sub-task level RocksDB file count metric

2024-02-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34334: --- Labels: pull-request-available (was: ) > Add sub-task level RocksDB file count metric >

Re: [PR] [FLINK-34455] Move RestoreMode from flink-runtime to flink-core [flink]

2024-02-18 Thread via GitHub
Zakelly commented on PR #24320: URL: https://github.com/apache/flink/pull/24320#issuecomment-1951061127 @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-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-02-18 Thread via GitHub
flinkbot commented on PR #24322: URL: https://github.com/apache/flink/pull/24322#issuecomment-1951070593 ## CI report: * 2b3519ac9c6810720536503e2eb777d8bc566a30 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34457] Rename options for latency tracking [flink]

2024-02-18 Thread via GitHub
Zakelly opened a new pull request, #24323: URL: https://github.com/apache/flink/pull/24323 ## What is the purpose of the change As one part of FLIP-406, this PR relocate the options for latency tracking under the prefix `state.latency-track`. ## Brief change log -

[jira] [Updated] (FLINK-34457) Rename options for latency tracking

2024-02-18 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34457: --- Labels: pull-request-available (was: ) > Rename options for latency tracking >

[jira] [Assigned] (FLINK-34252) WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under continuous data flow

2024-02-18 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan reassigned FLINK-34252: --- Assignee: David Christle > WatermarkAssignerOperator should not emit WatermarkStatus.IDLE under >

[jira] [Created] (FLINK-34457) Rename options for latency tracking

2024-02-18 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34457: --- Summary: Rename options for latency tracking Key: FLINK-34457 URL: https://issues.apache.org/jira/browse/FLINK-34457 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-33960) Adaptive Scheduler doesn't respect the lowerBound for tasks

2024-02-18 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17815475#comment-17815475 ] Rui Fan edited comment on FLINK-33960 at 2/18/24 9:38 AM: -- Merged to:

[jira] [Resolved] (FLINK-33960) Adaptive Scheduler doesn't respect the lowerBound for tasks

2024-02-18 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan resolved FLINK-33960. - Resolution: Fixed > Adaptive Scheduler doesn't respect the lowerBound for tasks >

Re: [PR] [FLINK-34362][docs] Add argument to skip integrate connector docs in setup_docs.sh to improve build times [flink]

2024-02-18 Thread via GitHub
swuferhong commented on code in PR #24271: URL: https://github.com/apache/flink/pull/24271#discussion_r1493723623 ## docs/setup_docs.sh: ## @@ -36,24 +36,34 @@ function integrate_connector_docs { } +SKIP_INTEGRATE_CONNECTOR_DOCS=false +for arg in "$@"; do + if [ "$arg" ==

Re: [PR] [FLINK-34266] Compute Autoscaler metrics correctly over metric window [flink-kubernetes-operator]

2024-02-18 Thread via GitHub
gyfora commented on code in PR #774: URL: https://github.com/apache/flink-kubernetes-operator/pull/774#discussion_r1493771207 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java: ## @@ -379,22 +484,75 @@ public static double getAverage(

Re: [PR] [FLINK-34266] Compute Autoscaler metrics correctly over metric window [flink-kubernetes-operator]

2024-02-18 Thread via GitHub
gyfora commented on code in PR #774: URL: https://github.com/apache/flink-kubernetes-operator/pull/774#discussion_r1493771147 ## flink-autoscaler/src/main/java/org/apache/flink/autoscaler/metrics/ScalingMetrics.java: ## @@ -223,128 +203,65 @@ public static void

Re: [PR] [FLINK-32075][FLIP-306][Checkpoint] Delete merged files on checkpoint abort or subsumption [flink]

2024-02-18 Thread via GitHub
Zakelly commented on PR #24181: URL: https://github.com/apache/flink/pull/24181#issuecomment-1951336353 @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] [Created] (FLINK-34459) Results column names should match SELECT clause expression names

2024-02-18 Thread Jeyhun Karimov (Jira)
Jeyhun Karimov created FLINK-34459: -- Summary: Results column names should match SELECT clause expression names Key: FLINK-34459 URL: https://issues.apache.org/jira/browse/FLINK-34459 Project: Flink

Re: [PR] [FLINK-25015][Table SQL] Use SQL string as jobName for DQL jobs submitted by sql-gateway [flink]

2024-02-18 Thread via GitHub
xiangyuf commented on PR #23455: URL: https://github.com/apache/flink/pull/23455#issuecomment-1951356537 Hi @libenchao @KarmaGYZ , can you kindly help review this when you have time? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[jira] [Closed] (FLINK-34391) Release Testing Instructions: Verify FLINK-15959 Add min number of slots configuration to limit total number of slots

2024-02-18 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee closed FLINK-34391. --- Resolution: Fixed [~xiangyu0xf] Thanks for the updating! > Release Testing Instructions: Verify

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

2024-02-18 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34399: --- Assignee: Ferenc Csaky > Release Testing: Verify FLINK-33644 Make QueryOperations SQL

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

2024-02-18 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818287#comment-17818287 ] lincoln lee commented on FLINK-34399: - [~ferenc-csaky] Thanks for taking this! Assigned to you. >

[jira] [Updated] (FLINK-34459) Results column names should match SELECT clause expression names

2024-02-18 Thread Jeyhun Karimov (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov updated FLINK-34459: --- Description: When printing {{SQL SELECT}} results, Flink will output generated expression