Hi, Milind. You may notice that these classes are tagged with 'Internal' and that mean they are may only used in flink itself. But I think you may do some retrofit work on flink, and it's a fast way to tag it as public and rebuild flink just for customization.
At 2022-06-24 06:27:43, "Milind Vaidya" <kava...@gmail.com> wrote: Hi I am trying to upgrade the version to 1.12. Some of the old code is using org.apache.flink.streaming.api.operators.async.queue.StreamRecordQueueEntry; This is no longer public in 1.12. Any pointers as to how to work around this? Thanks, Milind
