[PR] Cache Manifest files [iceberg-python]

2024-06-01 Thread via GitHub
chinmay-bhat opened a new pull request, #787: URL: https://github.com/apache/iceberg-python/pull/787 Closes #595. - add lru_cache() to manifests() - static method to avoid memory leaks I'm inclined to remove FileIO from the cache key as there's no significant difference in

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316927 ## open-api/rest-catalog-open-api.yaml: ## @@ -537,6 +537,124 @@ paths: 5XX: $ref: '#/components/responses/ServerErrorResponse' + /v1/{prefix}

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316927 ## open-api/rest-catalog-open-api.yaml: ## @@ -537,6 +537,124 @@ paths: 5XX: $ref: '#/components/responses/ServerErrorResponse' + /v1/{prefix}

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316927 ## open-api/rest-catalog-open-api.yaml: ## @@ -537,6 +537,124 @@ paths: 5XX: $ref: '#/components/responses/ServerErrorResponse' + /v1/{prefix}

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316927 ## open-api/rest-catalog-open-api.yaml: ## @@ -537,6 +537,124 @@ paths: 5XX: $ref: '#/components/responses/ServerErrorResponse' + /v1/{prefix}

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623330276 ## open-api/rest-catalog-open-api.yaml: ## @@ -537,6 +537,113 @@ paths: 5XX: $ref: '#/components/responses/ServerErrorResponse' + /v1/{prefix}

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623329917 ## open-api/rest-catalog-open-api.yaml: ## @@ -2106,6 +2210,32 @@ components: items: $ref: '#/components/schemas/PartitionStatisticsFile' +

[PR] Build: Bump software.amazon.awssdk:bom from 2.25.60 to 2.25.64 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] opened a new pull request, #10421: URL: https://github.com/apache/iceberg/pull/10421 Bumps software.amazon.awssdk:bom from 2.25.60 to 2.25.64. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=soft

[PR] Build: Bump com.azure:azure-sdk-bom from 1.2.23 to 1.2.24 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] opened a new pull request, #10420: URL: https://github.com/apache/iceberg/pull/10420 Bumps [com.azure:azure-sdk-bom](https://github.com/azure/azure-sdk-for-java) from 1.2.23 to 1.2.24. Release notes Sourced from https://github.com/azure/azure-sdk-for-java/releases";

[PR] Build: Bump net.snowflake:snowflake-jdbc from 3.16.0 to 3.16.1 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] opened a new pull request, #10419: URL: https://github.com/apache/iceberg/pull/10419 Bumps [net.snowflake:snowflake-jdbc](https://github.com/snowflakedb/snowflake-jdbc) from 3.16.0 to 3.16.1. Release notes Sourced from https://github.com/snowflakedb/snowflake-jdbc/

Re: [PR] Build: Bump com.google.errorprone:error_prone_annotations from 2.27.0 to 2.27.1 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] closed pull request #10268: Build: Bump com.google.errorprone:error_prone_annotations from 2.27.0 to 2.27.1 URL: https://github.com/apache/iceberg/pull/10268 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

Re: [PR] Build: Bump com.google.errorprone:error_prone_annotations from 2.27.0 to 2.27.1 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] commented on PR #10268: URL: https://github.com/apache/iceberg/pull/10268#issuecomment-2143694180 Superseded by #10418. -- 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 specifi

[PR] Build: Bump com.google.errorprone:error_prone_annotations from 2.27.0 to 2.28.0 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] opened a new pull request, #10418: URL: https://github.com/apache/iceberg/pull/10418 Bumps [com.google.errorprone:error_prone_annotations](https://github.com/google/error-prone) from 2.27.0 to 2.28.0. Release notes Sourced from https://github.com/google/error-prone

Re: [PR] Build: Bump com.google.cloud:libraries-bom from 26.28.0 to 26.39.0 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] commented on PR #10313: URL: https://github.com/apache/iceberg/pull/10313#issuecomment-2143694128 Superseded by #10417. -- 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 specifi

Re: [PR] Build: Bump com.google.cloud:libraries-bom from 26.28.0 to 26.39.0 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] closed pull request #10313: Build: Bump com.google.cloud:libraries-bom from 26.28.0 to 26.39.0 URL: https://github.com/apache/iceberg/pull/10313 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[PR] Build: Bump com.google.cloud:libraries-bom from 26.28.0 to 26.40.0 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] opened a new pull request, #10417: URL: https://github.com/apache/iceberg/pull/10417 Bumps [com.google.cloud:libraries-bom](https://github.com/googleapis/java-cloud-bom) from 26.28.0 to 26.40.0. Release notes Sourced from https://github.com/googleapis/java-cloud-bo

[PR] Build: Bump org.assertj:assertj-core from 3.25.3 to 3.26.0 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] opened a new pull request, #10416: URL: https://github.com/apache/iceberg/pull/10416 Bumps [org.assertj:assertj-core](https://github.com/assertj/assertj) from 3.25.3 to 3.26.0. Release notes Sourced from https://github.com/assertj/assertj/releases";>org.assertj:asse

[PR] Build: Bump org.xerial:sqlite-jdbc from 3.45.3.0 to 3.46.0.0 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] opened a new pull request, #10415: URL: https://github.com/apache/iceberg/pull/10415 Bumps [org.xerial:sqlite-jdbc](https://github.com/xerial/sqlite-jdbc) from 3.45.3.0 to 3.46.0.0. Release notes Sourced from https://github.com/xerial/sqlite-jdbc/releases";>org.xeri

[PR] Build: Bump guava from 33.2.0-jre to 33.2.1-jre [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] opened a new pull request, #10414: URL: https://github.com/apache/iceberg/pull/10414 Bumps `guava` from 33.2.0-jre to 33.2.1-jre. Updates `com.google.guava:guava` from 33.2.0-jre to 33.2.1-jre Release notes Sourced from https://github.com/google/guava/releases";>c

Re: [PR] Build: Bump mkdocs-material from 9.5.23 to 9.5.24 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] commented on PR #10380: URL: https://github.com/apache/iceberg/pull/10380#issuecomment-2143693759 Superseded by #10413. -- 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 specifi

Re: [PR] Build: Bump mkdocs-material from 9.5.23 to 9.5.24 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] closed pull request #10380: Build: Bump mkdocs-material from 9.5.23 to 9.5.24 URL: https://github.com/apache/iceberg/pull/10380 -- 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 sp

[PR] Build: Bump mkdocs-material from 9.5.23 to 9.5.25 [iceberg]

2024-06-01 Thread via GitHub
dependabot[bot] opened a new pull request, #10413: URL: https://github.com/apache/iceberg/pull/10413 Bumps [mkdocs-material](https://github.com/squidfunk/mkdocs-material) from 9.5.23 to 9.5.25. Release notes Sourced from https://github.com/squidfunk/mkdocs-material/releases";>mkdoc

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316927 ## open-api/rest-catalog-open-api.yaml: ## @@ -537,6 +537,124 @@ paths: 5XX: $ref: '#/components/responses/ServerErrorResponse' + /v1/{prefix}

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316927 ## open-api/rest-catalog-open-api.yaml: ## @@ -537,6 +537,124 @@ paths: 5XX: $ref: '#/components/responses/ServerErrorResponse' + /v1/{prefix}

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623317017 ## open-api/rest-catalog-open-api.yaml: ## @@ -537,6 +537,124 @@ paths: 5XX: $ref: '#/components/responses/ServerErrorResponse' + /v1/{prefix}

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316927 ## open-api/rest-catalog-open-api.yaml: ## @@ -537,6 +537,124 @@ paths: 5XX: $ref: '#/components/responses/ServerErrorResponse' + /v1/{prefix}

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316674 ## open-api/rest-catalog-open-api.yaml: ## @@ -3804,6 +4110,41 @@ components: } } +# Note that this is a representative example respon

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316510 ## open-api/rest-catalog-open-api.yaml: ## @@ -3804,6 +4110,41 @@ components: } } +# Note that this is a representative example respon

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316419 ## open-api/rest-catalog-open-api.yaml: ## @@ -3642,6 +3781,173 @@ components: type: integer description: "List of equality field IDs" +

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316399 ## open-api/rest-catalog-open-api.yaml: ## @@ -3642,6 +3781,173 @@ components: type: integer description: "List of equality field IDs" +

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316280 ## open-api/rest-catalog-open-api.yaml: ## @@ -3642,6 +3781,173 @@ components: type: integer description: "List of equality field IDs" +

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on code in PR #9695: URL: https://github.com/apache/iceberg/pull/9695#discussion_r1623316275 ## open-api/rest-catalog-open-api.yaml: ## @@ -3642,6 +3781,173 @@ components: type: integer description: "List of equality field IDs" +

Re: [PR] Add PrePlanTable and PlanTable Endpoints to open api spec [iceberg]

2024-06-01 Thread via GitHub
jackye1995 commented on PR #9695: URL: https://github.com/apache/iceberg/pull/9695#issuecomment-2143677634 Trying to revive this workstream based on what Rahil did and the discussions so far, I will put a few comments across the code to describe the rationales of a few places. This f

Re: [PR] docs(writer/docker): fix small typos and wording [iceberg-rust]

2024-06-01 Thread via GitHub
liurenjie1024 merged PR #389: URL: https://github.com/apache/iceberg-rust/pull/389 -- 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: issues-unsubscr...@ic

Re: [I] refactor: Remove `async_trait` in `Catalog` trait. [iceberg-rust]

2024-06-01 Thread via GitHub
liurenjie1024 commented on issue #139: URL: https://github.com/apache/iceberg-rust/issues/139#issuecomment-2143674376 > Is there any movement on this one? I see there was a prior PR to close, but it was closed pending upstream releases. > > If there's nobody working on it anymore, I w

[PR] to_arrow_batches to support returning Iterator[Recordbatch] instead of a fully materialized Arrow Table [iceberg-python]

2024-06-01 Thread via GitHub
syun64 opened a new pull request, #786: URL: https://github.com/apache/iceberg-python/pull/786 - Iterator[RecordBatch] is preferable for memory constrained applications - update `to_requested_schema` to take pa.RecordBatch instead of pa.Table Question: pyarrow schema is currently in

Re: [I] Implement Other Filesystems Using Go CDK [iceberg-go]

2024-06-01 Thread via GitHub
srilman commented on issue #92: URL: https://github.com/apache/iceberg-go/issues/92#issuecomment-2143658350 In addition, this library is one of the only ones available that supports AWS SDK v2 with write support. The library we are using right now, [S3IOFs](https://github.com/wolfeidau/s3io

[I] Implement Other Filesystems Using Go CDK [iceberg-go]

2024-06-01 Thread via GitHub
srilman opened a new issue, #92: URL: https://github.com/apache/iceberg-go/issues/92 ### Feature Request / Improvement The Go CDK (https://gocloud.dev/) is a semi-official interface for interactive with various cloud service solutions, providing common APIs. For the purposes of this

Re: [I] How do I find if there is residual in the table scan/plan files? [iceberg-python]

2024-06-01 Thread via GitHub
maytasm commented on issue #785: URL: https://github.com/apache/iceberg-python/issues/785#issuecomment-2143582071 Seems like we used to have something like https://github.com/apache/iceberg-python/commit/4f0a5c6203888ff105c1f09f41c17245f477d2ab but it's gone? @Fokko @TGooch44 -- This is

Re: [PR] Incremental Append Scan [iceberg-python]

2024-06-01 Thread via GitHub
chinmay-bhat commented on code in PR #533: URL: https://github.com/apache/iceberg-python/pull/533#discussion_r1623258053 ## pyiceberg/table/__init__.py: ## @@ -1754,6 +1788,134 @@ def to_arrow(self) -> pa.Table: def to_pandas(self, **kwargs: Any) -> pd.DataFrame: r

Re: [PR] Incremental Append Scan [iceberg-python]

2024-06-01 Thread via GitHub
chinmay-bhat commented on code in PR #533: URL: https://github.com/apache/iceberg-python/pull/533#discussion_r1623258053 ## pyiceberg/table/__init__.py: ## @@ -1754,6 +1788,134 @@ def to_arrow(self) -> pa.Table: def to_pandas(self, **kwargs: Any) -> pd.DataFrame: r

Re: [PR] Incremental Append Scan [iceberg-python]

2024-06-01 Thread via GitHub
chinmay-bhat commented on code in PR #533: URL: https://github.com/apache/iceberg-python/pull/533#discussion_r1623258053 ## pyiceberg/table/__init__.py: ## @@ -1754,6 +1788,134 @@ def to_arrow(self) -> pa.Table: def to_pandas(self, **kwargs: Any) -> pd.DataFrame: r

Re: [PR] Flink: Maintenance - MonitorSource [iceberg]

2024-06-01 Thread via GitHub
stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1623254132 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MonitorSource.java: ## @@ -0,0 +1,200 @@ +/* + * Licensed to the Apache Software Fo

Re: [I] refactor: Remove `async_trait` in `Catalog` trait. [iceberg-rust]

2024-06-01 Thread via GitHub
jdockerty commented on issue #139: URL: https://github.com/apache/iceberg-rust/issues/139#issuecomment-2143505467 Is there any movement on this one? I see there was a prior PR to close, but it was pending upstream changes. If there's nobody working on it anymore, I would like to take

Re: [PR] docs: Add links checker [iceberg]

2024-06-01 Thread via GitHub
manuzhang commented on PR #9965: URL: https://github.com/apache/iceberg/pull/9965#issuecomment-2143503093 I back-ported the fix to 1.5.x releases in #10411 -- 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] Docs: Fix internal links in 1.5.x releases [iceberg]

2024-06-01 Thread via GitHub
bitsondatadev commented on PR #10411: URL: https://github.com/apache/iceberg/pull/10411#issuecomment-2143501272 @manuzhang have you tried running this locally? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

Re: [PR] Spark 3.4: Only traverse ancestors of current snapshot when building changelog scan [iceberg]

2024-06-01 Thread via GitHub
flyrain commented on PR #10405: URL: https://github.com/apache/iceberg/pull/10405#issuecomment-2143501218 Thanks @manuzhang for working 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 URL above to go to th

Re: [PR] Spark 3.4: Only traverse ancestors of current snapshot when building changelog scan [iceberg]

2024-06-01 Thread via GitHub
flyrain merged PR #10405: URL: https://github.com/apache/iceberg/pull/10405 -- 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: issues-unsubscr...@iceberg.a

[PR] Docs: Fix internal links in 1.5.x releases [iceberg]

2024-06-01 Thread via GitHub
manuzhang opened a new pull request, #10411: URL: https://github.com/apache/iceberg/pull/10411 This fixes #10409, #10249 -- 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] Add Snowflake catalog [iceberg-python]

2024-06-01 Thread via GitHub
prabodh1194 commented on code in PR #687: URL: https://github.com/apache/iceberg-python/pull/687#discussion_r1623241664 ## pyiceberg/catalog/snowflake_catalog.py: ## @@ -0,0 +1,237 @@ +# Licensed to the Apache Software Foundation (ASF) under one +# or more contributor license ag

Re: [PR] Support getting snapshot at or right before the given timestamp [iceberg-python]

2024-06-01 Thread via GitHub
chinmay-bhat commented on code in PR #748: URL: https://github.com/apache/iceberg-python/pull/748#discussion_r1622175948 ## pyiceberg/table/__init__.py: ## @@ -1290,6 +1291,17 @@ def snapshot_by_name(self, name: str) -> Optional[Snapshot]: return self.snapshot_by_i

Re: [PR] Support getting snapshot at or right before the given timestamp [iceberg-python]

2024-06-01 Thread via GitHub
chinmay-bhat commented on code in PR #748: URL: https://github.com/apache/iceberg-python/pull/748#discussion_r1622175948 ## pyiceberg/table/__init__.py: ## @@ -1290,6 +1291,17 @@ def snapshot_by_name(self, name: str) -> Optional[Snapshot]: return self.snapshot_by_i

Re: [PR] feat: add `ExpressionEvaluator` [iceberg-rust]

2024-06-01 Thread via GitHub
marvinlanhenke commented on code in PR #363: URL: https://github.com/apache/iceberg-rust/pull/363#discussion_r1623218410 ## crates/iceberg/src/expr/visitors/expression_evaluator.rs: ## @@ -0,0 +1,819 @@ +// Licensed to the Apache Software Foundation (ASF) under one +// or more c

Re: [I] UUID type support in Spark is incomplete? [iceberg]

2024-06-01 Thread via GitHub
nastra commented on issue #4038: URL: https://github.com/apache/iceberg/issues/4038#issuecomment-2143378905 > hey nastra how can I use this fix #7399 using pyspark and aws glue? @igniris87 make sure to use Iceberg 1.3.0+ as this is the version where the fix was shipped with -- This

Re: [PR] Docs: Point links in metrics-reporting.md to GitHub Java source [iceberg]

2024-06-01 Thread via GitHub
nastra commented on code in PR #10397: URL: https://github.com/apache/iceberg/pull/10397#discussion_r1623188031 ## core/src/main/java/org/apache/iceberg/rest/RESTMetricsReporter.java: ## @@ -26,6 +26,10 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/** + * A {

Re: [PR] Docs: Point links in metrics-reporting.md to GitHub Java source [iceberg]

2024-06-01 Thread via GitHub
nastra commented on code in PR #10397: URL: https://github.com/apache/iceberg/pull/10397#discussion_r1623187528 ## core/src/main/java/org/apache/iceberg/rest/RESTMetricsReporter.java: ## @@ -26,7 +26,11 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; -class RESTM

Re: [I] bug: Iceberg opendal missing s3 support [iceberg-rust]

2024-06-01 Thread via GitHub
Xuanwo commented on issue #385: URL: https://github.com/apache/iceberg-rust/issues/385#issuecomment-2143364184 Let me fix this. -- 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 commen

Re: [PR] [Build] Add a script to execute revapi without gradle plugin [iceberg]

2024-06-01 Thread via GitHub
jbonofre commented on code in PR #10386: URL: https://github.com/apache/iceberg/pull/10386#discussion_r1623170105 ## dev/revapi: ## @@ -0,0 +1,88 @@ +#!/usr/bin/env bash + +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements.

Re: [PR] Flink: Maintenance - MonitorSource [iceberg]

2024-06-01 Thread via GitHub
pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1623167494 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MonitorSource.java: ## @@ -0,0 +1,200 @@ +/* + * Licensed to the Apache Software Founda

Re: [PR] Flink: Maintenance - MonitorSource [iceberg]

2024-06-01 Thread via GitHub
pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1623167111 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MonitorSource.java: ## @@ -0,0 +1,200 @@ +/* + * Licensed to the Apache Software Founda