Re: Flink 1.12 StreamRecordQueueEntry is not public class

2022-07-01 Thread Martijn Visser
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

Re: Flink 1.12 StreamRecordQueueEntry is not public class

2022-06-29 Thread Milind Vaidya
Thanks Xuyang, I did something similar to unblock myself. - Milind On Wed, Jun 29, 2022 at 8:40 PM Xuyang 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 fli

Flink 1.12 StreamRecordQueueEntry is not public class

2022-06-23 Thread Milind Vaidya
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