nk1506 commented on PR #8852:
URL: https://github.com/apache/iceberg/pull/8852#issuecomment-1770333911
Yeah sure @nastra . I will create PR with other versions.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
nastra commented on PR #8852:
URL: https://github.com/apache/iceberg/pull/8852#issuecomment-1767711923
thanks for reviewing @amogh-jahagirdar and @nk1506. @nk1506 would you be
interested in backporting this to older Flink versions?
--
This is an automated message from the Apache Git Servi
nastra merged PR #8852:
URL: https://github.com/apache/iceberg/pull/8852
--
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.apac
nastra commented on code in PR #8852:
URL: https://github.com/apache/iceberg/pull/8852#discussion_r1362375826
##
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java:
##
@@ -111,14 +113,19 @@ public void testConsumeWithoutStartSnapsho
nastra commented on code in PR #8852:
URL: https://github.com/apache/iceberg/pull/8852#discussion_r1362315314
##
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestIcebergSourceFailover.java:
##
@@ -98,9 +98,9 @@ protected List generateRecords(int numRecords, lo
nk1506 commented on code in PR #8852:
URL: https://github.com/apache/iceberg/pull/8852#discussion_r1362111563
##
flink/v1.17/flink/src/test/java/org/apache/iceberg/flink/source/TestStreamingMonitorFunction.java:
##
@@ -111,14 +113,19 @@ public void testConsumeWithoutStartSnapsho
