Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-05-15 Thread via GitHub
jeyhunkarimov commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1601116454 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -236,6 +238,9 @@ private void

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-05-15 Thread via GitHub
jeyhunkarimov commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1601116454 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -236,6 +238,9 @@ private void

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-05-15 Thread via GitHub
jeyhunkarimov commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1601116454 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -236,6 +238,9 @@ private void

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-05-14 Thread via GitHub
mumuhhh commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1600843684 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -236,6 +238,9 @@ private void

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-05-14 Thread via GitHub
mumuhhh commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1600843684 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -236,6 +238,9 @@ private void

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-05-14 Thread via GitHub
mumuhhh commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1600841072 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -115,7 +117,7 @@ private static class

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-28 Thread via GitHub
lsyldliu merged PR #24600: URL: https://github.com/apache/flink/pull/24600 -- 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-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-27 Thread via GitHub
lsyldliu commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1581993829 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -236,6 +238,9 @@ private void

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-27 Thread via GitHub
jeyhunkarimov commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1581891157 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/program/DynamicPartitionPruningProgramTest.java: ## @@ -81,6 +87,42

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-27 Thread via GitHub
jeyhunkarimov commented on PR #24600: URL: https://github.com/apache/flink/pull/24600#issuecomment-2081151799 Hi @lsyldliu thanks for the review. I addressed your comments. Could you please check in your available time? Thanks! -- This is an automated message from the Apache Git Service.

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-25 Thread via GitHub
lsyldliu commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1579386652 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -115,7 +117,7 @@ private static class

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-25 Thread via GitHub
lsyldliu commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1579356007 ## flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/optimize/program/DynamicPartitionPruningProgramTest.java: ## @@ -81,6 +87,42 @@

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-01 Thread via GitHub
jeyhunkarimov commented on code in PR #24600: URL: https://github.com/apache/flink/pull/24600#discussion_r1546924713 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/utils/DynamicPartitionPruningUtils.java: ## @@ -115,7 +117,7 @@ private static

Re: [PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-01 Thread via GitHub
flinkbot commented on PR #24600: URL: https://github.com/apache/flink/pull/24600#issuecomment-2030689199 ## CI report: * 06e59ca12ef6650b79e82fb513c47e53d90f052e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-34379][table] Fix OutOfMemoryError with large queries [flink]

2024-04-01 Thread via GitHub
jeyhunkarimov opened a new pull request, #24600: URL: https://github.com/apache/flink/pull/24600 ## What is the purpose of the change Fix OutOfMemoryError with large queries and when `table.optimizer.dynamic-filtering.enabled`. ## Brief change log - Fix the OOM cause