Hi Chetas,
How sure are you that your job has no other unbounded source?
I have seen this working in several cases, but if you could help with
providing a sort executable example, I would like to take a look.
Thanks,
Peter
On Wed, Mar 13, 2024, 20:55 Chetas Joshi wrote:
> Hello,
>
> I am
Hello,
I am using iceberg-flink-runtime lib (1.17-1.4.0) and running the following
code to read an iceberg table in BATCH mode.
var source = FlinkSource
.forRowData()
.streaming(false)
.env(execEnv)
.tableLoader(tableLoader)
.limit((long) operation.getLimit())
