[jira] [Updated] (FLINK-32049) CoordinatedSourceRescaleITCase.testDownscaling fails on AZP

2023-07-12 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rui Fan updated FLINK-32049: Attachment: logs-cron_azure-test_cron_azure_connect_2-1686196685.zip >

[GitHub] [flink] xuzifu666 commented on pull request #22980: [FLINK-31035] add warn info to user when NoNodeException happend

2023-07-12 Thread via GitHub
xuzifu666 commented on PR #22980: URL: https://github.com/apache/flink/pull/22980#issuecomment-1631927446 > ![image](https://user-images.githubusercontent.com/19502505/252874798-95938aed-9ea3-4790-b85e-375f1bacae2a.png) > > It has already failed. ok,got it,thx -- This is an

[GitHub] [flink] reswqa commented on pull request #22980: [FLINK-31035] add warn info to user when NoNodeException happend

2023-07-12 Thread via GitHub
reswqa commented on PR #22980: URL: https://github.com/apache/flink/pull/22980#issuecomment-1631926620 ![image](https://github.com/apache/flink/assets/19502505/95938aed-9ea3-4790-b85e-375f1bacae2a) It has already failed. -- This is an automated message from the Apache Git Service.

[GitHub] [flink] swuferhong commented on pull request #22966: [FLINK-32492][table-planner] Introduce FlinkRuntimeFilterProgram to apply the runtime filter optimization.

2023-07-12 Thread via GitHub
swuferhong commented on PR #22966: URL: https://github.com/apache/flink/pull/22966#issuecomment-1631926603 > Thanks for review @lsyldliu @swuferhong . All comments have been addressed or replied ,PTAL. Hi, Thanks! @wanglijie95 . Now LGTM for this PR. I wish the itcase can be

[jira] [Comment Edited] (FLINK-32049) CoordinatedSourceRescaleITCase.testDownscaling fails on AZP

2023-07-12 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742285#comment-17742285 ] Rui Fan edited comment on FLINK-32049 at 7/12/23 6:29 AM: -- Thanks report this

[jira] [Commented] (FLINK-32049) CoordinatedSourceRescaleITCase.testDownscaling fails on AZP

2023-07-12 Thread Rui Fan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17742285#comment-17742285 ] Rui Fan commented on FLINK-32049: - Thanks report this JIRA, and thanks [~Weijie Guo] 's analysis, there

[GitHub] [flink] xuzifu666 commented on pull request #22980: [FLINK-31035] add warn info to user when NoNodeException happend

2023-07-12 Thread via GitHub
xuzifu666 commented on PR #22980: URL: https://github.com/apache/flink/pull/22980#issuecomment-1631924924 > If I'm not mistaken, AZP is running well. Why you said that it cannot work 樂 in my view cannot see the aruze in link,if work well,please ignore my question~ @reswqa --

[GitHub] [flink] swuferhong commented on a diff in pull request #22966: [FLINK-32492][table-planner] Introduce FlinkRuntimeFilterProgram to apply the runtime filter optimization.

2023-07-12 Thread via GitHub
swuferhong commented on code in PR #22966: URL: https://github.com/apache/flink/pull/22966#discussion_r1260660398 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/program/FlinkRuntimeFilterProgramTest.java: ## @@ -0,0 +1,271 @@ +/* +

[GitHub] [flink] reswqa commented on pull request #22980: [FLINK-31035] add warn info to user when NoNodeException happend

2023-07-12 Thread via GitHub
reswqa commented on PR #22980: URL: https://github.com/apache/flink/pull/22980#issuecomment-1631923152 If I'm not mistaken, AZP is running well. Why you said that it cannot work 樂 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] xuzifu666 commented on pull request #22980: [FLINK-31035] add warn info to user when NoNodeException happend

2023-07-12 Thread via GitHub
xuzifu666 commented on PR #22980: URL: https://github.com/apache/flink/pull/22980#issuecomment-1631913010 > @flinkbot run azure why azure not work? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[GitHub] [flink] fredia commented on a diff in pull request #22772: [FLINK-19010][metric] Introduce subtask level restore metric

2023-07-12 Thread via GitHub
fredia commented on code in PR #22772: URL: https://github.com/apache/flink/pull/22772#discussion_r1260645282 ## flink-runtime/src/main/java/org/apache/flink/runtime/metrics/groups/TaskIOMetricGroup.java: ## @@ -67,10 +70,12 @@ public class TaskIOMetricGroup extends

[GitHub] [flink] flinkbot commented on pull request #22983: [FLINK-32049][checkpoint] Fix thread-safe bug of channel state executor when some subtasks are closed while other subtasks are starting

2023-07-12 Thread via GitHub
flinkbot commented on PR #22983: URL: https://github.com/apache/flink/pull/22983#issuecomment-1631906387 ## CI report: * 8c56e6e2f500223a8432a3fc80056c8aa243b7e1 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[GitHub] [flink] FangYongs commented on pull request #22938: [FLINK-32512] Don't register resource to user resource manager when creating temporary function

2023-07-12 Thread via GitHub
FangYongs commented on PR #22938: URL: https://github.com/apache/flink/pull/22938#issuecomment-1631903189 Hi @fsk119 , I have updated this PR, please help to review it again, thanks -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] xuzifu666 commented on pull request #22980: [FLINK-31035] add warn info to user when NoNodeException happend

2023-07-12 Thread via GitHub
xuzifu666 commented on PR #22980: URL: https://github.com/apache/flink/pull/22980#issuecomment-1631899521 @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-32049) CoordinatedSourceRescaleITCase.testDownscaling fails on AZP

2023-07-12 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-32049: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] 1996fanrui opened a new pull request, #22983: [FLINK-32049][checkpoint] Fix thread-safe bug of channel state executor when some subtasks are closed while other subtasks are starting

2023-07-12 Thread via GitHub
1996fanrui opened a new pull request, #22983: URL: https://github.com/apache/flink/pull/22983 ## What is the purpose of the change Fix thread-safe bug of channel state executor when some subtasks are closed while other subtasks are starting. ## Brief change log

<    1   2