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

github-actions[bot] commented on PR #11497: URL: https://github.com/apache/iceberg/pull/11497#issuecomment-2657973451 This pull request has been marked as stale due to 30 days of inactivity. It will be closed in 1 week if no further activity occurs. If you think that’s incorrect or this pul

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

pvary commented on PR #11497: URL: https://github.com/apache/iceberg/pull/11497#issuecomment-2589410701 > @pvary @stevenzwu Could we wrap this up? I don't see any fundamental issues here. The only open point from my perspective is table refresh during planning time, but even that could be h

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

mxm commented on PR #11497: URL: https://github.com/apache/iceberg/pull/11497#issuecomment-2589350651 @pvary @stevenzwu Could we wrap this up? I don't see any fundamental issues here. The only open point from my perspective is table refresh during planning time, but even that could be handl

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

github-actions[bot] commented on PR #11497: URL: https://github.com/apache/iceberg/pull/11497#issuecomment-2578930024 This pull request has been marked as stale due to 30 days of inactivity. It will be closed in 1 week if no further activity occurs. If you think that’s incorrect or this pul

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

mxm commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1876313019 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java: ## @@ -0,0 +1,26 @@ +/* + * Licensed to the Apache Software Foundation (ASF

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

mxm commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1876313019 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java: ## @@ -0,0 +1,26 @@ +/* + * Licensed to the Apache Software Foundation (ASF

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1874112948 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java: ## @@ -0,0 +1,26 @@ +/* + * Licensed to the Apache Software Foundation (A

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1874111940 ## flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestRewriteDataFiles.java: ## @@ -0,0 +1,447 @@ +/* + * Licensed to the Apache Software Foun

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

mxm commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1873507376 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softwar

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

mxm commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1873496955 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java: ## @@ -0,0 +1,26 @@ +/* + * Licensed to the Apache Software Foundation (ASF

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1873000874 ## flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/api/TestRewriteDataFiles.java: ## @@ -0,0 +1,447 @@ +/* + * Licensed to the Apache Software Foun

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872999804 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java: ## @@ -0,0 +1,26 @@ +/* + * Licensed to the Apache Software Foundation (A

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872997729 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872987060 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872983141 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,320 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872976559 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872296533 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache S

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870369893 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache S

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872290014 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache S

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872286319 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foun

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872275998 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,230 @@ +/* + * Licensed to the Apache So

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872272095 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872272095 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872273140 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foun

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1872270885 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,320 @@ +/* + * Licensed to the Apache

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

mxm commented on PR #11497: URL: https://github.com/apache/iceberg/pull/11497#issuecomment-2520575831 Concerning your questions in https://github.com/apache/iceberg/pull/11497#issuecomment-2519720233, my preferences are the same as yours: - **State handling and restoration**: I prefe

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

mxm commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1869581998 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LogUtil.java: ## @@ -0,0 +1,26 @@ +/* + * Licensed to the Apache Software Foundation (ASF

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

pvary commented on PR #11497: URL: https://github.com/apache/iceberg/pull/11497#issuecomment-2520330145 Added a PR to remove the state handling (we can still revert if we decide so) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1871013622 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on PR #11497: URL: https://github.com/apache/iceberg/pull/11497#issuecomment-2519720233 To summarise the state, I see the following open questions: - State handling and restoration - How to handle table schema, specification, configuration changes - How to handle erro

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870855184 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870881421 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,320 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870870693 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,320 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870870094 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,320 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870867735 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870866818 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870860620 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870859167 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870853511 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,230 @@ +/* + * Licensed to the Apache Softwa

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870852664 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,230 @@ +/* + * Licensed to the Apache Softwa

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870851241 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,230 @@ +/* + * Licensed to the Apache Softwa

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870848822 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,320 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870847371 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,320 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870844610 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870843942 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foundati

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870155972 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,320 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870222639 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870189780 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache Softwa

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870135670 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache So

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870150019 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foun

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870135670 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache So

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870135670 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache So

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870023392 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1870028597 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache

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

pvary commented on PR #11497: URL: https://github.com/apache/iceberg/pull/11497#issuecomment-2517874597 #11131 changed how the delete files are removed. See: https://github.com/apache/iceberg/pull/11131#issuecomment-2517865727 -- This is an automated message from the Apache Git Service. T

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1869055997 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1869075731 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,318 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1869204818 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1869200284 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1869049426 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1869089070 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,318 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1869052950 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1869049426 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868988254 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868782263 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868806860 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache Softwa

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868801347 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868809006 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,318 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868782263 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868455346 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache So

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868471586 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache S

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868466879 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foun

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868461497 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResultAggregator.java: ## @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Soft

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868392426 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868436095 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,318 @@ +/* + * Licensed to the Apache

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1866780897 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache So

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868426860 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868393393 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache

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

stevenzwu commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868379639 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868114928 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache Softwa

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868109673 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868103159 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868101342 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868100304 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResultAggregator.java: ## @@ -0,0 +1,154 @@ +/* + * Licensed to the Apache Software

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868098943 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868096866 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868096866 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868095868 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868091732 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868087488 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1868086690 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1867878070 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1867869970 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1867834564 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1867817542 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1867809765 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteCommitter.java: ## @@ -0,0 +1,304 @@ +/* + * Licensed to the Apache Soft

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1867807035 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/api/RewriteDataFiles.java: ## @@ -0,0 +1,232 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1867134750 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewriteExecutor.java: ## @@ -0,0 +1,257 @@ +/* + * Licensed to the Apache Softw

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1867148777 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache Softwa

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

pvary commented on code in PR #11497: URL: https://github.com/apache/iceberg/pull/11497#discussion_r1867146642 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DataFileRewritePlanner.java: ## @@ -0,0 +1,228 @@ +/* + * Licensed to the Apache Softwa

  1   2   >