Thanks Xuyang, I did something similar to unblock myself.
- Milind On Wed, Jun 29, 2022 at 8:40 PM Xuyang <xyzhong...@163.com> wrote: > 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 > >
