#oozie #oozie-workflow
Вопрос:
Я работаю над созданием рабочего процесса для отслеживания некоторых нулевых значений в моих таблицах правил, из которых один из столбцов для мониторинга-это проверка % изменений таблицы со вчерашнего дня по сегодняшний день, для этого я написал свой pyscript следующим образом
def calculate_size_increase(tblname): df = None q_last_run_date = "select scvcju_run_time_s as last_run_date, scvcju_total_records_in_column_r as last_count from " db_name "." master_table " where scvcju_rules_table_name_x = '" tblname "'" df = spark.sql(q_last_run_date) if df.count() == 0: return 100 else: last_run_date= df.sort(df.last_run_date.desc()).first().last_run_date last_count=df.sort(df.last_run_date.desc()).first().last_count q_todays_count = "select count(1) as c from " db_name "." tblname df = spark.sql(q_todays_count) todays_count = df.first().c return 100 * ((todays_count - last_count) / last_count)
Я получаю эту ошибку при запуске рабочего процесса
Ошибка ZeroDivisionError: целочисленное деление или по модулю на ноль