MLE-26838: Added null check for conf.getStrings() method in various files

NOTICE.txt

@@ -1,4 +1,4 @@
-MarkLogic® Content Pump 12.0
+Progress® MarkLogic® Content Pump 12.0.1
 
 Copyright © 2011-2025 Progress Software Corporation and/or its subsidiaries or affiliates. All Rights Reserved.
 
@@ -10,10 +10,10 @@ Unless required by applicable law or agreed to in writing, software distributed
 
 To the extent required by the applicable open-source license, a complete machine-readable copy of the source code corresponding to such code is available upon request. This offer is valid to anyone in receipt of this information and shall expire three years following the date of the final distribution of this product version by Progress Software Corporation. To obtain such source code, send an email to Legal-thirdpartyreview@progress.com. Please specify the product and version for which you are requesting source code.
 
-The following software may be included in MarkLogic® Content Pump 12.0
-(last updated July 14, 2025):
 -------------------------------------------------------------------------
 
+The following software may be included in Progress® MarkLogic® Content Pump 12.0.1 (last updated November 24, 2025):
+
 Third Party Components
 
 avro 1.11.4 (Apache-2.0)
@@ -444,7 +444,7 @@ THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
 
 Common Licenses
 
-This section shows the text of common third-party licenses used by MarkLogic® Content Pump v12.0:
+This section shows the text of common third-party licenses used by Progress® MarkLogic® Content Pump v12.0.1:
 
 Apache License 2.0 (Apache-2.0)
 https://spdx.org/licenses/Apache-2.0.html

README.md

@@ -15,7 +15,11 @@ The MarkLogic Connector for Hadoop is an extension to Hadoop’s MapReduce frame
 
 ## Release Notes
 
-### What's New in mlcp 12.0
+### What's New in mlcp 12.0.1
+
+- No new updates
+
+### What's New in mlcp 12.0.0
 
 - Replaced the commons-csv-marklogic library with the standard Apache Commons CSV library for improved compatibility and maintainability
 - Upgraded commons-csv and commons-io libraries to the latest stable versions.

pom.xml

@@ -3,7 +3,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.marklogic</groupId>
   <artifactId>mlcp</artifactId>
-  <version>12.0</version>
+  <version>12.0.1</version>
   <name>MarkLogic Content Pump</name>
   <description>MarkLogic Content Pump</description>
   <url>https://github.com/marklogic/marklogic-contentpump</url>
@@ -17,7 +17,7 @@
   </licenses>
 
   <properties>
-    <versionString>12.0</versionString>
+    <versionString>12.0.1</versionString>
     <xccVersion>${versionString}</xccVersion>
     <hadoopVersion>3.4.0</hadoopVersion>
     <jacksonVersion>2.17.1</jacksonVersion>

src/main/java/com/marklogic/contentpump/InputType.java

@@ -249,6 +249,10 @@ public void applyConfigOptions(Configuration conf, CommandLine cmdline)
             ContentSource cs;
             String[] outputHosts =
                     conf.getStrings(MarkLogicConstants.OUTPUT_HOST);
+            if (outputHosts == null || outputHosts.length == 0) {
+                throw new IllegalArgumentException(MarkLogicConstants.OUTPUT_HOST + 
+                        " is not specified.");
+            }
             int hostIdx = 0;
             while (hostIdx < outputHosts.length) {
                 try {

src/main/java/com/marklogic/contentpump/RDFReader.java

@@ -546,8 +546,13 @@ public void initExistingMapPerms() throws IOException {
         ResultSequence result = null;
         ContentSource cs;
         try {
+            String[] hosts = conf.getStrings(MarkLogicConstants.OUTPUT_HOST);
+            if (hosts == null || hosts.length == 0) {
+                throw new IllegalArgumentException(MarkLogicConstants.OUTPUT_HOST + 
+                        " is not specified.");
+            }
             cs = InternalUtilities.getOutputContentSource(conf,
-                conf.getStrings(MarkLogicConstants.OUTPUT_HOST)[0]);
+                hosts[0]);
             session = cs.newSession();
             RequestOptions options = new RequestOptions();
             options.setDefaultXQueryVersion("1.0-ml");

src/main/java/com/marklogic/contentpump/ThreadManager.java

@@ -556,6 +556,10 @@ public void run() {
                     }
                 }
                 String[] hosts = conf.getStrings(MarkLogicConstants.OUTPUT_HOST);
+                if (hosts == null || hosts.length == 0) {
+                    throw new IllegalArgumentException(MarkLogicConstants.OUTPUT_HOST + 
+                            " is not specified.");
+                }
                 for (String host : hosts) {
                     try {
                         ContentSource cs = InternalUtilities.

src/main/java/com/marklogic/contentpump/TransformOutputFormat.java

@@ -75,6 +75,10 @@ private LinkedMapWritable getMimetypesMap() throws IOException {
             return mimetypeMap;
         }
         String[] hosts = conf.getStrings(OUTPUT_HOST);
+        if (hosts == null || hosts.length == 0) {
+            throw new IllegalArgumentException(OUTPUT_HOST + 
+                    " is not specified.");
+        }
         Session session = null;
         ResultSequence result = null;
 

src/main/java/com/marklogic/contentpump/utilities/PermissionUtil.java

@@ -79,8 +79,13 @@ public static List<ContentPermission> getDefaultPermissions(Configuration conf,
         ResultSequence result = null;
         ContentSource cs;
         try {
+            String[] hosts = conf.getStrings(MarkLogicConstants.OUTPUT_HOST);
+            if (hosts == null || hosts.length == 0) {
+                throw new IllegalArgumentException(MarkLogicConstants.OUTPUT_HOST + 
+                        " is not specified.");
+            }
             cs = InternalUtilities.getOutputContentSource(conf,
-                conf.getStrings(MarkLogicConstants.OUTPUT_HOST)[0]);
+                hosts[0]);
 
             session = cs.newSession();
             RequestOptions options = new RequestOptions();

src/main/java/com/marklogic/mapreduce/ContentOutputFormat.java

@@ -224,6 +224,10 @@ public void checkOutputSpecs(
                 TextArrayWritable hostArray = null;
                 if (restrictHosts) {
                     String[] outputHosts = conf.getStrings(OUTPUT_HOST);
+                    if (outputHosts == null || outputHosts.length == 0) {
+                        throw new IllegalArgumentException(OUTPUT_HOST + 
+                                " is not specified.");
+                    }
                     hostArray = new TextArrayWritable(outputHosts);
                 } else {
                     String outputHost = cs.getConnectionProvider().getHostName();

src/main/java/com/marklogic/mapreduce/utilities/InternalUtilities.java

@@ -104,11 +104,12 @@ public class InternalUtilities implements MarkLogicConstants {
      */
     public static ContentSource getInputContentSource(Configuration conf) 
     throws URISyntaxException, XccConfigException, IOException {
-        String host = conf.getStrings(INPUT_HOST)[0];
-        if (host == null || host.isEmpty()) {
+        String[] hosts = conf.getStrings(INPUT_HOST);
+        if (hosts == null || hosts.length == 0) {
             throw new IllegalArgumentException(INPUT_HOST + 
                     " is not specified.");
         }
+        String host = hosts[0];
 
         return getInputContentSource(conf, host);
     }