From 22c3ce73dbaca70ec0eceee721bb9fbd344c2331 Mon Sep 17 00:00:00 2001
From: Sivabalan Narayanan <n.siva.b@gmail.com>
Date: Mon, 14 Mar 2022 15:34:17 -0700
Subject: [PATCH] [HUDI-3621] Fixing NullPointerException in DeltaStreamer
 (#5039)

---
 .../org/apache/hudi/utilities/deltastreamer/DeltaSync.java  | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
index 2a319308f..7dd9a3689 100644
--- a/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
+++ b/hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
@@ -910,6 +910,10 @@ public class DeltaSync implements Serializable {
    * @return Requested clustering instant.
    */
   public Option<String> getClusteringInstantOpt() {
-    return writeClient.scheduleClustering(Option.empty());
+    if (writeClient != null) {
+      return writeClient.scheduleClustering(Option.empty());
+    } else {
+      return Option.empty();
+    }
   }
 }