lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-3621] Fixing NullPointerException in DeltaStreamer (#5039)

Browse Source
This commit is contained in:
Sivabalan Narayanan
2022-03-14 15:34:17 -07:00
committed by GitHub
parent 003c6ee73e
commit 22c3ce73db
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java
View File

@@ -910,6 +910,10 @@ public class DeltaSync implements Serializable {
* @return Requested clustering instant. * @return Requested clustering instant.
*/ */
public Option<String> getClusteringInstantOpt() { public Option<String> getClusteringInstantOpt() {
if (writeClient != null) {
return writeClient.scheduleClustering(Option.empty()); return writeClient.scheduleClustering(Option.empty());
} else {
return Option.empty();
}
} }
} }