io.hops.util.exceptions.FeaturestoreNotFound logged/thrown during the Kafka tour

Description

```
io.hops.util.exceptions.FeaturestoreNotFound: Could not fetch featuregroups for featurestore:demo_kafka_admin000_featurestore
at io.hops.util.FeaturestoreRestClient.getFeaturestoreMetadataRest(FeaturestoreRestClient.java:60)
at io.hops.util.featurestore.ops.write_ops.FeaturestoreUpdateMetadataCache.write(FeaturestoreUpdateMetadataCache.java:38)
at io.hops.util.Hops.setup(Hops.java:142)
at io.hops.util.Hops.<clinit>(Hops.java:106)
at io.hops.examples.spark.kafka.StructuredStreamingKafka$.main(StructuredStreamingKafka.scala:38)
at io.hops.examples.spark.kafka.StructuredStreamingKafka.main(StructuredStreamingKafka.scala)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.spark.deploy.yarn.ApplicationMaster$$anon$2.run(ApplicationMaster.scala:679)
```

The above exception is thrown (or logged) during the Kafka tour as the featurestore is not created (and it should not be required).

Either we find a better way to figured out if the job requires the featurestore information or we should handle better the exception during the setup.

Assignee

Kim Hammar

Reporter

Fabio Buso

Labels

None

Fix versions

Priority

Medium
Configure