diff --git a/sdk/python/feast/infra/contrib/spark_kafka_processor.py b/sdk/python/feast/infra/contrib/spark_kafka_processor.py index c8b24f2a82..04901d64e4 100644 --- a/sdk/python/feast/infra/contrib/spark_kafka_processor.py +++ b/sdk/python/feast/infra/contrib/spark_kafka_processor.py @@ -11,6 +11,7 @@ from feast.data_source import KafkaSource, PushMode from feast.expediagroup.schema_registry.schema_registry import SchemaRegistry from feast.feature_store import FeatureStore +from feast.feature_view import FeatureView from feast.infra.contrib.stream_processor import ( ProcessorConfig, StreamProcessor,