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

pvary merged PR #10308: URL: https://github.com/apache/iceberg/pull/10308 -- 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.apa

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1628951961 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on PR #10308: URL: https://github.com/apache/iceberg/pull/10308#issuecomment-2151632301 Merged to main. Thanks for the review @rodmeneses and @stevenzwu! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

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

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1626655524 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Softwar

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1626517533 ## 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]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1626516787 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,344 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1626475908 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Software Fo

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

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1626255534 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1626274743 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,344 @@ +/* + * Licensed to the Apache Softwar

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

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1626263978 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Softwar

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

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1626255534 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625869218 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,344 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625868760 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,344 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625867192 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625866835 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software Found

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625864926 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625862231 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625861166 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625860108 ## 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]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625856014 ## 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]

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

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625828013 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,344 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625822325 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625817607 ## 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]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625128576 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,344 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625118113 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,132 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625114795 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software Found

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1625114022 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software Found

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

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1624777278 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software F

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

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: [PR] Flink: Maintenance - MonitorSource [iceberg]

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]

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

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

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

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

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1622721206 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apa

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

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1622689279 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1622689279 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1622689279 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1622578621 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1622578621 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1622579093 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1622579093 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1622578621 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

gyfora commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1613226726 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1610991960 ## 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]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1608720543 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,195 @@ +/* + * Licensed to the Apa

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1608734772 ## 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]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1608734772 ## 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]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1608725056 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1608717408 ## 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]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1608709287 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1608678483 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1608691840 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apa

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

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1608678483 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1605953735 ## 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]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1605660593 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1605579104 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1605572493 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java: ## @@ -0,0 +1,127 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1605569731 ## 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]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1605569145 ## 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]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1605564238 ## 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]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1605562862 ## 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]

stevenzwu commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1605496877 ## 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: [PR] Flink: Maintenance - MonitorSource [iceberg]

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601589261 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ManualSource.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Software Foundat

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601585403 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,338 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601318958 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,338 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601318215 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ManualSource.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Software Foundat

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601317394 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ManualSource.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Software Foundat

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601316408 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkStreamingTestUtils.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache Softwa

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601312872 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkStreamingTestUtils.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache Softwa

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601312090 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,145 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601301144 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,145 @@ +/* + * Licensed to the Apache Software Fo

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601296963 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software Found

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601295680 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software Found

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601295173 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software Found

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601292857 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java: ## @@ -0,0 +1,127 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601292448 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java: ## @@ -0,0 +1,127 @@ +/* + * Licensed to the Apache Software Foundati

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601291444 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601291185 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601289077 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601287576 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apache

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

pvary commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1601279619 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/SingleThreadedIteratorSource.java: ## @@ -0,0 +1,196 @@ +/* + * Licensed to the Apache

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

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

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

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

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

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

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

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

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

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

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600393564 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,338 @@ +/* + * Licensed to the Apache Softwa

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600392955 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestMonitorSource.java: ## @@ -0,0 +1,338 @@ +/* + * Licensed to the Apache Softwa

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600391516 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ManualSource.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Software Fo

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600391271 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ManualSource.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Software Fo

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600390832 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ManualSource.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Software Fo

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600389873 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/ManualSource.java: ## @@ -0,0 +1,160 @@ +/* + * Licensed to the Apache Software Fo

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600389281 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkStreamingTestUtils.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache S

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600387856 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkStreamingTestUtils.java: ## @@ -0,0 +1,73 @@ +/* + * Licensed to the Apache S

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600387151 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,145 @@ +/* + * Licensed to the Apache Softwa

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600386331 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/FlinkSqlExtension.java: ## @@ -0,0 +1,145 @@ +/* + * Licensed to the Apache Softwa

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600383869 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600382928 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600382039 ## flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/CollectingSink.java: ## @@ -0,0 +1,115 @@ +/* + * Licensed to the Apache Software

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

rodmeneses commented on code in PR #10308: URL: https://github.com/apache/iceberg/pull/10308#discussion_r1600379428 ## flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableChange.java: ## @@ -0,0 +1,127 @@ +/* + * Licensed to the Apache Software Fou

  1   2   >