advance.
Thanks
Siva
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
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
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
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
.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
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
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.
ber.
- I tried changing the type to string. Still it is printing as "NULL"
- If I send a malformed JSON in the key, Flink is throwing an error. So,
it is clear that Flink is trying to parse the key field as JSON. But why is
it printing as "NULL" in the select query output?
Can anyone please advise what I am doing wrong?
Thanks,
Siva
