USER
Error in SQL statement: AnalysisException: Column 'act.payload__status' does not exist. Did you mean one of the following? [act.payload____v, act.payload__id, act.payload___id__oid, act.payload__is_deleted, act.payload__seller_id, seller.payload__tags, act.payload__seller_code, act.payload__serial_number, act.payload__terminal_id, act.kafka_source, act.metadata___data, act.payload__connectivity, seller.payload__contacts, seller.payload__note, act.payload__schema_version, act.payload__situation__status, act.payload__token__code, act.delta_timestamp, act.metadata__db, act.offset, seller.payload____v, act.payload__equipment_type, act.payload__terminal_code, act.timestamp, act.country, act.day, act.metadata__coll, act.month, act.payload__created_at__date, act.payload__fulfillment_id, act.payload__terminal_brand, act.payload__terminal_model, act.payload__updated_at__date, act.tenant, act.year, seller.payload___id__oid, act.payload__attempts_activate, seller.payload__is_deleted, seller.payload__seller_id, seller.payload__web_page, seller.payload__affiliations, act.payload__created_date__date, seller.payload__merchant_id, seller.payload__seller_type, seller.payload__trade_name, seller.offset, seller.payload__seller_code, seller.timestamp, seller.country, seller.day, seller.kafka_source, seller.metadata___data, seller.metadata__db, seller.month, act.payload__activated_date__date, seller.payload__entity_version, act.payload__fulfillment_item_id, act.payload__migration_date__date, seller.payload__receipt_name, seller.payload__schema_version, seller.payload__situation__status, seller.payload__working_hours, seller.tenant, seller.year, seller.delta_timestamp, seller.payload__approval_date, seller.payload__phone__number, seller.payload__situation__reason, act.payload__token__situation__status, seller.metadata__coll, act.metadata__operation_type, seller.payload__country_origin, seller.payload__created_at__date, act.payload__deactivated_date__date, seller.payload__updated_at__date, seller.payload__deactivation_code, seller.payload__main_seller_type, act.payload__send_certificate_attempt, act.metadata__cluster_time__inc, seller.payload__migration__origin, seller.payload__phone__area_code, act.metadata__cluster_time__value, seller.payload__billing_descriptor, seller.payload__merchant_account_id, seller.payload__supporting_documents, seller.payload__approval_date__date, seller.payload__audit_information_id, act.metadata__cluster_time__seconds, seller.metadata__ingestion_type, seller.payload__phone__country_code, seller.metadata__operation_type, seller.payload__migration__responsible, act.payload__token__expiration_date__date, seller.metadata__cluster_time__inc, seller.metadata__cluster_time__value, seller.payload__commercial_address__city, seller.payload__commercial_address__state, seller.payload__migration__mapping_fields, seller.payload__migration__situation__status, seller.payload__category_free_description, seller.payload__commercial_address__suite, act.payload__situation__status_update_date__date, seller.metadata__cluster_time__seconds, seller.payload__commercial_address__number, seller.payload__commercial_address__street, seller.payload__creation_information__email, seller.payload__commercial_address__country, seller.payload__commercial_address__district, seller.payload__creation_information__channel, seller.payload__seller_pre_approval_temp_code, seller.payload__commercial_address__complement, seller.payload__commercial_address__postal_code, seller.payload__commercial_address__street_type, seller.payload__migration__origin_situation_status, seller.payload__commercial_information__currency, seller.payload__situation__status_update_date__date, act.payload__token__situation__status_update_date__date, seller.payload__commercial_address_reference_point1, seller.payload__commercial_address_reference_point2, seller.payload__migration__origin_creation_date__date, seller.payload__commercial_information__average_ticket, seller.payload__creation_information__creation_date__date, seller.payload__migration__situation__update_status_date__date, seller.payload__commercial_information__gross_monthly_income, seller.payload__migration__origin_last_status_update_date__date, seller.payload__economic_activity_profile__merchant_category_code, seller.payload__commercial_information__gross_monthly_digital_payments, seller.payload__economic_activity_profile__acquirer_merchant_category_code]; line 31 pos 8;
'WithCTE
:- 'CTERelationDef 6
: +- 'SubqueryAlias ActiveSellers
: +- 'Project ['COUNT(distinct 'seller.payload__seller_code) AS total_active_sellers#10191]
: +- 'Filter (((country#10388 = CL) AND (payload__equipment_type#10451 = smart_pos)) AND ('act.payload__status = active))
: +- Join Inner, (payload__seller_code#10351 = payload__seller_code#10425)
: :- SubqueryAlias seller
: : +- SubqueryAlias hive_metastore.delta.`/pnms/stage/event/onboarding/seller_ms/seller/current/`
: : +- Relation [offset#10328,timestamp#10329,year#10330,month#10331,day#10332,delta_timestamp#10333,kafka_source#10334,payload____v#10335,payload__affiliations#10336,payload__audit_information_id#10337,payload__billing_descriptor#10338,payload__category_free_description#10339,payload__commercial_address_reference_point1#10340,payload__commercial_address_reference_point2#10341,payload__contacts#10342,payload__deactivation_code#10343,payload__entity_version#10344,payload__is_deleted#10345,payload__merchant_account_id#10346,payload__merchant_id#10347,payload__note#10348,payload__receipt_name#10349,payload__schema_version#10350,payload__seller_code#10351,... 58 more fields] parquet
: +- SubqueryAlias act
: +- SubqueryAlias hive_metastore.delta.`/pnms/stage/event/payment_channel/terminal_activation_ms/terminal/current`
: +- Relation [offset#10410,timestamp#10411,year#10412,month#10413,day#10414,delta_timestamp#10415,kafka_source#10416,payload____v#10417,payload__attempts_activate#10418,payload__connectivity#10419,payload__fulfillment_id#10420,payload__fulfillment_item_id#10421,payload__id#10422,payload__is_deleted#10423,payload__schema_version#10424,payload__seller_code#10425,payload__seller_id#10426,payload__serial_number#10427,payload__terminal_brand#10428,payload__terminal_code#10429,payload__terminal_id#10430,payload__terminal_model#10431,metadata___data#10432,metadata__coll#10433,... 22 more fields] parquet
:- 'CTERelationDef 7
: +- 'SubqueryAlias UniqueSerialNumbers
: +- 'Project ['COUNT(distinct 'payload__serial_number) AS total_unique_serial_numbers#10192]
: +- 'Filter ((country#10495 = CL) AND ('payload__status = active))
: +- SubqueryAlias hive_metastore.delta.`/pnms/stage/event/payment_channel/terminal_activation_ms/terminal/current`
: +- Relation [offset#10456,timestamp#10457,year#10458,month#10459,day#10460,delta_timestamp#10461,kafka_source#10462,payload____v#10463,payload__attempts_activate#10464,payload__connectivity#10465,payload__fulfillment_id#10466,payload__fulfillment_item_id#10467,payload__id#10468,payload__is_deleted#10469,payload__schema_version#10470,payload__seller_code#10471,payload__seller_id#10472,payload__serial_number#10473,payload__terminal_brand#10474,payload__terminal_code#10475,payload__terminal_id#10476,payload__terminal_model#10477,metadata___data#10478,metadata__coll#10479,... 22 more fields] parquet
+- 'Aggregate [scalar-subquery#10182 [] AS total_clientes_ativos#10183, scalar-subquery#10184 [] AS total_terminais_unicos#10185, 'COUNT(distinct 'pay.payload__terminal__terminal_code) AS num_terminais_com_transacoes#10186, 'COUNT(distinct 'act.payload__terminal_code) AS total_terminais_campo#10187, count(1) AS total_transacoes#10188L, 'SUM('nam.payload__transaction__amount) AS total_aprovado_euro#10189, 'SUM('nam.payload__transaction__mdr_amount) AS total_mdr_euro#10190]
: :- 'Project ['total_active_sellers]
: : +- 'SubqueryAlias ActiveSellers
: : +- 'CTERelationRef 6, false
: +- 'Project ['total_unique_serial_numbers]
: +- 'SubqueryAlias UniqueSerialNumbers
: +- 'CTERelationRef 7, false
+- 'Filter ((('act.country = CL) AND ('MONTH('pay.timestamp) = 10)) AND (('act.payload__equipment_type = smart_pos) AND ('pay.payload__reason_message = Approved)))
+- 'Join LeftOuter, ('pay.payload__payment_id = 'nam.payload__transaction__payment_id)
:- 'Join LeftOuter, ((('pay.country = 'act.country) AND ('pay.tenant = 'act.tenant)) AND (('pay.payload__seller_code = 'act.payload__seller_code) AND ('pay.payload__terminal__terminal_code = 'act.payload__terminal_code)))
: :- 'Join LeftOuter, (((country#10562 = country#10623) AND (tenant#10561 = tenant#10622)) AND ((payload__seller_code#10525 = payload__seller_code#10599) AND ('act.payload__status = active)))
: : :- SubqueryAlias seller
: : : +- SubqueryAlias hive_metastore.delta.`/pnms/stage/event/onboarding/seller_ms/seller/current/`
: : : +- Relation [offset#10502,timestamp#10503,year#10504,month#10505,day#10506,delta_timestamp#10507,kafka_source#10508,payload____v#10509,payload__affiliations#10510,payload__audit_information_id#10511,payload__billing_descriptor#10512,payload__category_free_description#10513,payload__commercial_address_reference_point1#10514,payload__commercial_address_reference_point2#10515,payload__contacts#10516,payload__deactivation_code#10517,payload__entity_version#10518,payload__is_deleted#10519,payload__merchant_account_id#10520,payload__merchant_id#10521,payload__note#10522,payload__receipt_name#10523,payload__schema_version#10524,payload__seller_code#10525,... 58 more fields] parquet
: : +- SubqueryAlias act
: : +- SubqueryAlias hive_metastore.delta.`/pnms/stage/event/payment_channel/terminal_activation_ms/terminal/current`
: : +- Relation [offset#10584,timestamp#10585,year#10586,month#10587,day#10588,delta_timestamp#10589,kafka_source#10590,payload____v#10591,payload__attempts_activate#10592,payload__connectivity#10593,payload__fulfillment_id#10594,payload__fulfillment_item_id#10595,payload__id#10596,payload__is_deleted#10597,payload__schema_version#10598,payload__seller_code#10599,payload__seller_id#10600,payload__serial_number#10601,payload__terminal_brand#10602,payload__terminal_code#10603,payload__terminal_id#10604,payload__terminal_model#10605,metadata___data#10606,metadata__coll#10607,... 22 more fields] parquet
: +- SubqueryAlias pay
: +- SubqueryAlias hive_metastore.delta.`/pnms/stage/event/payment/payment_ms/payment/current`
: +- Relation [offset#10905,timestamp#10906,year#10907,month#10908,day#10909,delta_timestamp#10910,kafka_source#10911,payload____v#10912,payload__acquirer_code#10913,payload__acquirer_country_code#10914,payload__action_code#10915,payload__affiliation_seller_code#10916,payload__amount#10917,payload__authenticated#10918,payload__authorization_code#10919,payload__authorizer_response_code#10920,payload__billing_descriptor#10921,payload__brand#10922,payload__capture#10923,payload__capture_date#10924,payload__capture_mode#10925,payload__currency#10926,payload__currency_code#10927,payload__date_undo_limit#10928,... 205 more fields] parquet
+- SubqueryAlias nam
+- SubqueryAlias hive_metastore.delta.`/pnms/stage/event/nam/nam_financial_movements_ms/movements/current`
+- Relation [offset#11470,timestamp#11471,year#11472,month#11473,day#11474,delta_timestamp#11475,kafka_source#11476,payload____v#11477,payload__currency#11478,payload__financial_movements_id#11479,payload__financial_movements_type#11480,payload__gross_value#11481,payload__id#11482,payload__is_deleted#11483,payload__merchant_id#11484,payload__net_value#11485,payload__schema_version#11486,payload__seller_id#11487,payload__settlement_batch_id#11488,payload__settlement_status#11489,payload__settlement_status_history#11490,payload__settlement_tax_id#11491,payload__taxes#11492,payload__transaction_identifier#11493,... 312 more fields] parquet