Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-04-28 Thread via GitHub
JingGe merged PR #23470: URL: https://github.com/apache/flink/pull/23470 -- 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-32622][table-planner] Optimize mini-batch assignment [flink]

2024-04-26 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-2078737997 Hi @xuyangzhong thanks for the comment. I addressed your comments. Please, let me know if you agree. -- This is an automated message from the Apache Git Service. To respond to

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-04-25 Thread via GitHub
xuyangzhong commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1578935653 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -46,11 +47,14 @@

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-04-17 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-2061766848 Thanks a lot @xuyangzhong for your review. I addressed your comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-04-15 Thread via GitHub
xuyangzhong commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1565689466 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/MiniBatchOptimizationTest.java: ## @@ -0,0 +1,169 @@ +/* + * Licensed

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-18 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-189848 @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-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-17 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-1896341427 @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-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-17 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-1896275667 @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-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-17 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-1895850048 @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-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-189017 Hi @JingGe @xuyangzhong thanks for your reviews. I updated the PR addressing your comments. I think the CI failure is not related to this PR -- This is an automated message from

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451764950 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451763272 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451763251 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451763129 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-14 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1451762837 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/analyze/MiniBatchOptimizationTest.java: ## @@ -0,0 +1,169 @@ +/* + * Licensed to

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-08 Thread via GitHub
jeyhunkarimov commented on PR #23470: URL: https://github.com/apache/flink/pull/23470#issuecomment-1881785044 Hi @JingGe @xuyangzhong thank you for your reviews. I am very sorry, somehow I haven't noticed your reviews in time. I will address your comments and update the PR ASAP. --

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-08 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1445302785 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2024-01-08 Thread via GitHub
jeyhunkarimov commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1445302785 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2023-11-20 Thread via GitHub
xuyangzhong commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r148054 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@

Re: [PR] [FLINK-32622][table-planner] Optimize mini-batch assignment [flink]

2023-11-20 Thread via GitHub
JingGe commented on code in PR #23470: URL: https://github.com/apache/flink/pull/23470#discussion_r1399813069 ## flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/optimize/StreamCommonSubGraphBasedOptimizer.scala: ## @@ -50,14 +51,23 @@ class