Я пытаюсь написать фреймворк, используя spark-sql для переноса данных из оракула в кассандру, используя datastax-connector.Как обработать ошибки, если есть какие-либо разрывы соединения?В sqoop мы помещаем его в промежуточные таблицы, затем обрабатываем данные, здесь в spark-sql нам нужны промежуточные таблицы / области?если так, как обращаться / проектировать это?Пожалуйста, помогите мне ~ спасибо.