Re: Location of source for flink-connector-aws-kinesis-streams ?

2025-01-31 Thread Aleksandr Pilipenko
Hi, Connector sources are located in Flink AWS connectors repo: https://github.com/apache/flink-connector-aws/tree/main/flink-connector-aws/flink-connector-aws-kinesis-streams Regards, Aleksandr On Fri, 31 Jan 2025 at 17:21, Anderson, Michael via user < user@flink.apache.org> wrote: > Hi, > > I

Location of source for flink-connector-aws-kinesis-streams ?

2025-01-31 Thread Anderson, Michael via user
Hi, I have been looking for the source for the flink-connector-aws-kinesis-streams package, but I can't find it - maybe because of the recent name change. Could you let me know where it is? Regards, Mike

Paimon missing CatalogFactory

2025-01-31 Thread Dominik.Buenzli
Hi Flink Community I’m currently trying to get Paimon running in our k8s environment with Flink SQL (v1.19.1). I added the dependencies to our Flink SQL-Runner as well as the lib folder of the docker image: "org.apache.paimon" % "paimon-flink" % "1.0.0", "org.apache.pa

Re: Please help with Flink + InfluxDB

2025-01-31 Thread Nikola Milutinovic
Hi Siva. In this case, extensive logging is in order. Now, you should be aware that if you want to track progress of data in your pipeline, you need to log statements inside your processors, sinks,… On our project we made a small LogProcessingFunction, which was just outputting log statement we