Re: Question on flink connector

2021-10-20 Thread Sijie Guo
Hi Vijaya, Can you report the issue in the Flink Jira? We will follow up on the memory leak issue. The source connector was released as part of Flink 1.14 is a new implementation based on the new Flink source API. If you are using Flink 1.12 or older versions, you can use this connector ( https:/

Question on flink connector

2021-10-17 Thread vijaya bhaskar
We have evaluated pulsar in the last few months and would like to use it with flink. Found that memory leak with Java-11 flink connector. https://nightlies.apache.org/flink/flink-docs-master/zh/release-notes/flink-1.14/ Now in a dilemma whether pulsar is matured to use in streaming space as with K