Prashant Singh
Prashant Singh
one more idea on this context and at a higher level, is that can we prefetch next task and keep it in memory and expose an iterator around it, when...
cc @aokolnychyi
> @singhpk234 is there any benchmark result to show? @ConeyLiu working on the benchmarks
superceded by https://github.com/apache/iceberg/pull/11180
sounds fair !
@HarshitGupta11 if possible can you please bump this to 2.25.70 instead, we are pursuing another change from s3 which is required from S3 Access grants which release contains i.e support...
@cccs-jc this is interesting, question is is the consumed offset properly committed in the scenario ? 1. did you check this offset json in the offset directory ? 2. is...
Haven't been looking into this actively. couple of questions : > That's because it applies the stream-from-timestamp when in fact it should not look at it at all but instead...
I see so what i was trying to say is that latestOffset() API which you linked in the ticket is working right, as if it's giving the latestOffset it can...
@cccs-jc no i wasn't i tried this unit test : ``` @TestTemplate public void testResumingStreamReadFromCheckpointWithStreamFromTimestamp() throws Exception { File writerCheckpointFolder = temp.resolve("writer-checkpoint-folder").toFile(); File writerCheckpoint = new File(writerCheckpointFolder, "writer-checkpoint"); File output...