Когда завершен один конвейер и если состояние является ошибкой, я хочу обновить столбец таблицы базы данных, чтобы записать состояние ошибки.
PipelineResult result = p.run();
IInternationalIngestionDb db = InternationalDbConnection.getInternationalIngestionDb(options.getDbConfigFile().get(),options.getDbName().get());
boolean upd = db.ingestionRequests().find(Long.parseLong("11091")).setErrorCode(-88888).save();
result.waitUntilFinish();
Я хочу использовать приведенный выше код тестирования для обновления базы данных. Но это не сработало.
Может ли кто-то иметь какие-то мнения?