Accommodating for hops-util API changes.

Author: tkakantousis

spark/src/main/java/io/hops/examples/spark/WorkflowExample.java

@@ -6,6 +6,8 @@
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import javax.ws.rs.core.Response;
+
+import io.hops.util.exceptions.WorkflowManagerException;
 import org.apache.spark.sql.SparkSession;
 
 /**
@@ -18,7 +20,8 @@ public class WorkflowExample {
 
   private static final Logger LOG = Logger.getLogger(WorkflowManager.class.getName());
 
-  public static void main(String[] args) throws CredentialsNotFoundException, InterruptedException {
+  public static void main(String[] args)
+      throws CredentialsNotFoundException, InterruptedException, WorkflowManagerException {
 
     SparkSession spark = SparkSession
         .builder()

spark/src/main/java/io/hops/examples/spark/kafka/StreamingKafkaElastic.java

@@ -3,6 +3,7 @@
 import com.google.common.base.Strings;
 import io.hops.util.exceptions.CredentialsNotFoundException;
 import io.hops.util.HopsUtil;
+import io.hops.util.exceptions.WorkflowManagerException;
 import io.hops.util.spark.SparkConsumer;
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -120,7 +121,8 @@ public void call(JavaRDD<LogEntryFilebeat> rdd, Time time) throws Exception {
     HopsUtil.shutdownGracefully(jssc);
   }
 
-  private static JSONObject parser(String logType, String line, String appId) throws CredentialsNotFoundException {
+  private static JSONObject parser(String logType, String line, String appId)
+      throws CredentialsNotFoundException, WorkflowManagerException {
     JSONObject jsonLog = new JSONObject(line);
     JSONObject index = new JSONObject();
     String priority, logger, thread, timestamp;