diff --git a/demos/data-lakehouse-iceberg-trino-spark/create-nifi-ingestion-job.yaml b/demos/data-lakehouse-iceberg-trino-spark/create-nifi-ingestion-job.yaml
index e86947df..64673a6b 100644
--- a/demos/data-lakehouse-iceberg-trino-spark/create-nifi-ingestion-job.yaml
+++ b/demos/data-lakehouse-iceberg-trino-spark/create-nifi-ingestion-job.yaml
@@ -16,6 +16,8 @@ spec:
             - pipefail
             - -c
             - |
+              echo 'Waiting for all nifi nodes to be ready'
+              kubectl wait --for=condition=ready --timeout=30m pod -l app.kubernetes.io/instance=nifi,app.kubernetes.io/name=nifi
               echo 'Waiting for all kafka brokers to be ready'
               kubectl wait --for=condition=ready --timeout=30m pod -l app.kubernetes.io/instance=kafka,app.kubernetes.io/name=kafka
       containers: