Hi everybody,

I faced a strange error in hive this morning.

The error message is this one :

FAILED: Execution Error, return code 2 from
org.apache.hadoop.hive.ql.exec.MapRedTask

after a quick search on Google, it appears that this is a Hive bug :

https://issues.apache.org/jira/browse/HIVE-4650

Is there a way to pass through this error ?

Thanks.

NB : my hive script is in the attachment.


-- 
*Jérôme VERDIER*
06.72.19.17.31
verdier.jerom...@gmail.com
INSERT INTO TABLE default.THM_RENTA_RGRP_PRODUITS_JOUR

  SELECT * FROM (

        -- Cumul OS
        SELECT

          '${hiveconf:in_co_societe}'          as co_societe, -- A modifier
          renta_prod.dt_jour,
          renta_prod.type_entite,
          renta_prod.code_entite,
          renta_prod.type_rgrp_produits        as type_rgrp_produits,
          renta_prod.co_rgrp_produits          as co_rgrp_produits,
          renta_prod.co_type_ref,
          -2                                   as co_os,
          renta_prod.co_trad_ls                as co_trad_ls,
          min(flg_demarque_valide)             as flg_demarque_valide,
          sum(me_vente_ht)                     as me_vente_ht,
          sum(me_marge_avt_dem)                as me_marge_avt_dem,
          sum(me_cession)                      as me_cession,
          sum(qt_vente)                        as qt_vente,
          sum(me_stickers)                     as me_stickers,
          sum(MT_CA_BRUT_TTC)                  as MT_CA_BRUT_TTC,
          SUM(MT_AVANTAGE_AFFECTE)             as MT_AVANTAGE_AFFECTE,
          SUM(MT_AVANTAGE_NON_AFFECTE)         as MT_AVANTAGE_NON_AFFECTE,
          SUM(MT_COUPON)                       as MT_COUPON,
          NULL                                                                  
         as FLG_DEM_INC_PRX_CS_VAL,
          SUM(MT_CHEQUE_FIDELITE_TTC)          as MT_CHEQUE_FIDELITE_TTC,
          SUM(MT_CA_NET_TTC)                   as MT_CA_NET_TTC,
          SUM(MT_CHEQUE_FIDELITE_HT)           as MT_CHEQUE_FIDELITE_HT,
          SUM(NB_PT_AFFECTE)                   as NB_PT_AFFECTE,
          SUM(NB_PT_VALORISE_HT)               as NB_PT_VALORISE_HT,
          SUM(MT_PT_NON_AFFECTE_HT)            as MT_PT_NON_AFFECTE_HT,
          SUM(MT_POINTS_FINANCES_HT)           as MT_POINTS_FINANCES_HT,
          SUM(MT_REMISE_IMMEDIATE_MP_FIN_HT)   as MT_REMISE_IMMEDIATE_MP_FIN_HT,
          SUM(MT_TARIF_BRUT_TTC)               as MT_TARIF_BRUT_TTC,
          sum(me_dem_prx_cs)                   as me_dem_prx_cs,
          sum(me_dem_con_prx_cs)               as me_dem_con_prx_cs,
          sum(me_dem_inc_prx_cs)               as me_dem_inc_prx_cs,
          sum(me_dem_prov_stk_cs)              as me_dem_prov_stk_cs,
          sum(qt_dem)                          as qt_dem,
          sum(qt_dem_con)                      as qt_dem_con,
          sum(qt_dem_inc)                      as qt_dem_inc,
          sum(qt_dem_prov_stk)                 as qt_dem_prov_stk
        from
          default.THM_RENTA_RGRP_PRODUITS_JOUR renta_prod
        WHERE
            renta_prod.co_societe = '${hiveconf:in_co_societe}' --A modifier
        and renta_prod.dt_jour = '${hiveconf:in_dt_jour}' -- A modifier
        and renta_prod.co_os >= 0
        GROUP BY
          renta_prod.dt_jour,
          renta_prod.type_entite,
          renta_prod.code_entite,
          renta_prod.type_rgrp_produits,
          renta_prod.co_rgrp_produits,
          renta_prod.co_type_ref,
          renta_prod.co_trad_ls
        
        UNION ALL

        -- Cumul Total
        SELECT
          '${hiveconf:in_co_societe}'          as co_societe, -- A modifier
          renta_prod.dt_jour,
          renta_prod.type_entite,
          renta_prod.code_entite,
          renta_prod.type_rgrp_produits        as type_rgrp_produits,
          renta_prod.co_rgrp_produits          as co_rgrp_produits,
          renta_prod.co_type_ref,
          -3                                   as co_os,
          renta_prod.co_trad_ls                as co_trad_ls,
          min(flg_demarque_valide)             as flg_demarque_valide,
          sum(me_vente_ht)                     as me_vente_ht,
          sum(me_marge_avt_dem)                as me_marge_avt_dem,
          sum(me_cession)                      as me_cession,
          sum(qt_vente)                        as qt_vente,
          sum(me_stickers)                     as me_stickers,
          sum(MT_CA_BRUT_TTC)                  as MT_CA_BRUT_TTC,
          SUM(MT_AVANTAGE_AFFECTE)             as MT_AVANTAGE_AFFECTE,
          SUM(MT_AVANTAGE_NON_AFFECTE)         as MT_AVANTAGE_NON_AFFECTE,
          SUM(MT_COUPON)                       as MT_COUPON,
          NULL                                 as FLG_DEM_INC_PRX_CS_VAL,
          SUM(MT_CHEQUE_FIDELITE_TTC)          as MT_CHEQUE_FIDELITE_TTC,
          SUM(MT_CA_NET_TTC)                   as MT_CA_NET_TTC,
          SUM(MT_CHEQUE_FIDELITE_HT)           as MT_CHEQUE_FIDELITE_HT,
          SUM(NB_PT_AFFECTE)                   as NB_PT_AFFECTE,
          SUM(NB_PT_VALORISE_HT)               as NB_PT_VALORISE_HT,
          SUM(MT_PT_NON_AFFECTE_HT)            as MT_PT_NON_AFFECTE_HT,
          SUM(MT_POINTS_FINANCES_HT)           as MT_POINTS_FINANCES_HT,
          SUM(MT_REMISE_IMMEDIATE_MP_FIN_HT)   as MT_REMISE_IMMEDIATE_MP_FIN_HT,
          SUM(MT_TARIF_BRUT_TTC)               as MT_TARIF_BRUT_TTC,
          sum(me_dem_prx_cs)                   as me_dem_prx_cs,
          sum(me_dem_con_prx_cs)               as me_dem_con_prx_cs,
          sum(me_dem_inc_prx_cs)               as me_dem_inc_prx_cs,
          sum(me_dem_prov_stk_cs)              as me_dem_prov_stk_cs,
          sum(qt_dem)                          as qt_dem,
          sum(qt_dem_con)                      as qt_dem_con,
          sum(qt_dem_inc)                      as qt_dem_inc,
          sum(qt_dem_prov_stk)                 as qt_dem_prov_stk
        from
          default.THM_RENTA_RGRP_PRODUITS_JOUR renta_prod
        WHERE
            renta_prod.co_societe = '${hiveconf:in_co_societe}' -- A modifier
        and renta_prod.dt_jour = '${hiveconf:in_dt_jour}' -- A modifier
        and renta_prod.co_os >= -1
        GROUP BY
          renta_prod.dt_jour,
          renta_prod.type_entite,
          renta_prod.code_entite,
          renta_prod.type_rgrp_produits,
          renta_prod.co_rgrp_produits,
          renta_prod.co_type_ref,
          renta_prod.co_trad_ls) test;

Reply via email to