Skip to content

Commit 8234c8e

Browse files
authored
Merge pull request #491 from marklogic/feature/more-polaris
Hopefully last medium Polaris fix
2 parents 0e8f1cf + 1923cb6 commit 8234c8e

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

marklogic-spark-api/src/main/java/com/marklogic/spark/core/classifier/TextClassifierFactory.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
import com.marklogic.spark.dom.DOMHelper;
1212
import com.smartlogic.classificationserver.client.ClassificationConfiguration;
1313
import com.smartlogic.cloud.CloudException;
14+
import com.smartlogic.cloud.Token;
1415
import com.smartlogic.cloud.TokenFetcher;
1516
import org.w3c.dom.Document;
1617

@@ -19,6 +20,7 @@
1920
import java.net.URL;
2021
import java.util.HashMap;
2122
import java.util.Map;
23+
import java.util.Objects;
2224

2325
public abstract class TextClassifierFactory {
2426

@@ -65,7 +67,9 @@ protected static ClassificationConfiguration buildClassificationConfiguration(Co
6567
private static String generateApiToken(ConfigHelper configHelper, String apiKey) {
6668
TokenFetcher tokenFetcher = new TokenFetcher(configHelper.getTokenUrl().toString(), apiKey);
6769
try {
68-
return tokenFetcher.getAccessToken().getAccess_token();
70+
Token token = tokenFetcher.getAccessToken();
71+
Objects.requireNonNull(token);
72+
return token.getAccess_token();
6973
} catch (CloudException e) {
7074
throw new ConnectorException(String.format("Unable to generate token for classifying text; cause: %s", e.getMessage()), e);
7175
}

0 commit comments

Comments
 (0)