mpleStringSchema()) \
.build()
data_stream = env.from_source(source,
WatermarkStrategy.for_monotonous_timestamps(), "Kafka Source")
# Process each Kafka message and map it to InfluxDB write
data_stream.map(lambda msg: process_kafka_message(msg))
env.execute("Kafka to InfluxDB Stream")
Please help to fix this,
Thanks,
Siva Rama Krishna.
Can you please provide how you are submitting the Python job via JM.
Siva,.
On Thu, Feb 13, 2025 at 3:44 PM Nikola Milutinovic
wrote:
> OK, you are running into some Flink weirdness here. And it is with PyFlink
> and how it runs.
>
>
>
> What machine are you trying to run the
.20.0.jar
flink-shaded-netty-tcnative-dynamic-2.0.59.Final-17.0.jar
flink-table-planner_2.12-1.20.0.jar
Please help.
Thanking you,
Siva Rama Krishna
On Fri, Jan 31, 2025 at 2:16 PM Nikola Milutinovic
wrote:
> Hi Siva.
>
>
>
> In this case, extensive logging is in order. Now, you
Yes Nix.
I can confirm that I am able to connect to InfluxDB from Flink(taskmanager).
URL="http://influxdb:8086";
And also, I tried with below from inside Flink(taskmanager) container
and that also worked.
curl influxdb:8086
Siva.
On Thu, Jan 30, 2025 at 4:50 PM Nikola Milutinovic
wro
r InfluxDB).
Maybe I need to correct my volumes paths or something?
Warm regards,
Siva Rama Krishna.
On Thu, Jan 30, 2025 at 2:05 PM Nikola Milutinovic
wrote:
>
> Hi Siva.
>
>
>
> What is the InfluxDB URL you are using? I assume it is something like
> “influxdb://influxdb:80
Hi, I am trying to create a data streaming pipeline for real-time analytics.
Kafka -> Flink -> InfluDB -> Visualize
I am facing an issue writing the data to InfluxDB. I can see logs in
'taskmanager' after submitting the Job. But, the data is not being
written to InfluxDB for some reason.
Please h
Hi Till,
Thanks for your response. I m able to use flink-connector-kafka-0.9-2_11
with Kafka v10 to produce and consume messages.
Thanks,
Sivakumar Bhavanari.
On Mon, Aug 1, 2016 at 6:41 AM, Till Rohrmann wrote:
> Hi Siva,
>
> in version 1.0.0 we’ve added the Scala binary version
advance.
Thanks
Siva
