What I'm interested in is understanding why you're relying on this class; what is the problem you're trying to solve? That input could be useful to consider making that interface public or there could be another way to solve your problem.
Best regards, Martijn Op wo 29 jun. 2022 om 18:12 schreef Milind Vaidya <[email protected]>: > Thanks Xuyang, > > I did something similar to unblock myself. > > - Milind > > On Wed, Jun 29, 2022 at 8:40 PM Xuyang <[email protected]> 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" <[email protected]> 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 >> >>
