From 408188d2b02f563c0150ed12936f884370832034 Mon Sep 17 00:00:00 2001 From: Razvan-Daniel Mihai <84674+razvan@users.noreply.github.com> Date: Wed, 29 Oct 2025 11:07:10 +0100 Subject: [PATCH] fix:nifi ingestion jobs urls --- .../create-nifi-ingestion-job.yaml | 2 +- .../create-nifi-ingestion-job.yaml | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml b/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml index 15f2807e..f078bf87 100644 --- a/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml +++ b/demos/nifi-kafka-druid-earthquake-data/create-nifi-ingestion-job.yaml @@ -76,7 +76,7 @@ data: service_login(username=USERNAME, password=PASSWORD) print("Logged in") - response = requests.get("https://raw.githubusercontent.com/stackabletech/demos/refs/heads/main/demos/nifi-kafka-druid-earthquake-data/IngestEarthquakesToKafka.json") + response = requests.get("https://raw.githubusercontent.com/stackabletech/demos/refs/heads/release-25.7/demos/nifi-kafka-druid-earthquake-data/IngestEarthquakesToKafka.json") filename = "/tmp/IngestEarthquakesToKafka.json" with open(filename, "wb") as f: f.write(response.content) diff --git a/demos/nifi-kafka-druid-water-level-data/create-nifi-ingestion-job.yaml b/demos/nifi-kafka-druid-water-level-data/create-nifi-ingestion-job.yaml index f02c6f08..a9160838 100644 --- a/demos/nifi-kafka-druid-water-level-data/create-nifi-ingestion-job.yaml +++ b/demos/nifi-kafka-druid-water-level-data/create-nifi-ingestion-job.yaml @@ -76,7 +76,7 @@ data: service_login(username=USERNAME, password=PASSWORD) print("Logged in") - response = requests.get("https://raw.githubusercontent.com/stackabletech/demos/refs/heads/main/demos/nifi-kafka-druid-water-level-data/IngestWaterLevelsToKafka.json") + response = requests.get("https://raw.githubusercontent.com/stackabletech/demos/refs/heads/release-25.7/demos/nifi-kafka-druid-water-level-data/IngestWaterLevelsToKafka.json") filename = "/tmp/IngestWaterLevelsToKafka.json" with open(filename, "wb") as f: