________________________________ From: Emil Hjelle (ekstern) <emil.hje...@elvia.no> Sent: Wednesday, November 27, 2024 4:35 PM To: dev@flink.apache.org <dev@flink.apache.org> Subject: Upsert to Kafka with flink SQL
Hi! I am new to Flink and not sure if this is the right place to ask this question. I am trying to create a demo of Flink SQL with the Kubernetes operator. I am using the example from https://github.com/apache/flink-kubernetes-operator/tree/main/examples/flink-sql-runner-example I have modified sample.sql, pom.xml and Dockerfile to the files included in this e-mail. Everything looks good in the UI when port-forward the rest service and I can also see that I am consuming data from the source topic in the Confluent platform, but the data don't show up in the sink topic. Do you have any advice on how to debug this problem? Kind regards Emil Hjelle
