Uploaded image for project: 'Hive'
  1. Hive
  2. HIVE-7657

Map of union of 3 or more types cannot be joined

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: None
    • Fix Version/s: None
    • Labels:

      Description

      Joining table which contains map of union of 3 types or more is causing serialization issues.

      Given tables:
      ag_map_of_uniontype:

      # col_name data_type comment
      hash string None
      custom_fields map<string,uniontype<bigint,double,string,boolean,int,array<uniontype<bigint,double,string,boolean,int>>,map<string,uniontype<bigint,double,string,boolean,int>>>> None
      

      ag_simple_join_table:

      # col_name data_type comment
      hash string None
      size int None
      

      Query will throw java.lang.RuntimeException:

      select
      i.hash,
      i.custom_fields,
      b.size
      from ag_map_of_uniontype i LEFT OUTER JOIN
      ag_simple_join_table b ON (i.hash = b.hash);
      
      org.apache.hadoop.hive.ql.exec.MapJoinOperator: Unxpected exception: java.util.ArrayList cannot be cast to org.apache.hadoop.hive.serde2.objectinspector.UnionObject
      java.lang.ClassCastException: java.util.ArrayList cannot be cast to org.apache.hadoop.hive.serde2.objectinspector.UnionObject
      	at org.apache.hadoop.hive.serde2.objectinspector.StandardUnionObjectInspector.getTag(StandardUnionObjectInspector.java:91)
      	at org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe.serialize(LazySimpleSerDe.java:559)
      	at org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe.serialize(LazySimpleSerDe.java:529)
      	at org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe.serializeField(LazySimpleSerDe.java:439)
      	at org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe.serialize(LazySimpleSerDe.java:423)
      	at org.apache.hadoop.hive.ql.exec.FileSinkOperator.processOp(FileSinkOperator.java:618)
      	at org.apache.hadoop.hive.ql.exec.Operator.process(Operator.java:504)
      	at org.apache.hadoop.hive.ql.exec.Operator.forward(Operator.java:847)
      	at org.apache.hadoop.hive.ql.exec.SelectOperator.processOp(SelectOperator.java:87)
      	at org.apache.hadoop.hive.ql.exec.Operator.process(Operator.java:504)
      	at org.apache.hadoop.hive.ql.exec.Operator.forward(Operator.java:847)
      	at org.apache.hadoop.hive.ql.exec.CommonJoinOperator.genAllOneUniqueJoinObject(CommonJoinOperator.java:671)
      	at org.apache.hadoop.hive.ql.exec.CommonJoinOperator.checkAndGenObject(CommonJoinOperator.java:754)
      	at org.apache.hadoop.hive.ql.exec.MapJoinOperator.processOp(MapJoinOperator.java:222)
      	at org.apache.hadoop.hive.ql.exec.Operator.process(Operator.java:504)
      	at org.apache.hadoop.hive.ql.exec.Operator.forward(Operator.java:847)
      	at org.apache.hadoop.hive.ql.exec.TableScanOperator.processOp(TableScanOperator.java:91)
      	at org.apache.hadoop.hive.ql.exec.Operator.process(Operator.java:504)
      	at org.apache.hadoop.hive.ql.exec.Operator.forward(Operator.java:847)
      	at org.apache.hadoop.hive.ql.exec.MapOperator.process(MapOperator.java:519)
      	at org.apache.hadoop.hive.ql.exec.mr.ExecMapper.map(ExecMapper.java:157)
      	at org.apache.hadoop.mapred.MapRunner.run(MapRunner.java:50)
      	at org.apache.hadoop.mapred.MapTask.runOldMapper(MapTask.java:417)
      	at org.apache.hadoop.mapred.MapTask.run(MapTask.java:332)
      	at org.apache.hadoop.mapred.Child$4.run(Child.java:268)
      	at java.security.AccessController.doPrivileged(Native Method)
      	at javax.security.auth.Subject.doAs(Subject.java:415)
      	at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1554)
      	at org.apache.hadoop.mapred.Child.main(Child.java:262)
      
      org.apache.hadoop.hive.ql.metadata.HiveException: Hive Runtime Error while processing row {"hash":"nzM2VsRBJReFrv4fGeSX","custom_fields":{"listOfIntegers":{5:[{4:10},{4:28},{4:42},{4:51},{4:63},{4:92},{4:113},{4:126},{4:128},{4:130},{4:144},{4:145},{4:146},{4:179},{4:182},{4:198},{4:225},{4:260},{4:232},{4:233},{4:237},{4:238},{4:255}]}}}
      
      

        Attachments

          Activity

            People

            • Assignee:
              singhashish Ashish Singh
              Reporter:
              argasi Arkadiusz Gasior
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated: