Skip to content
Snippets Groups Projects
  • Davies Liu's avatar
    4a377aff
    [SPARK-3721] [PySpark] broadcast objects larger than 2G · 4a377aff
    Davies Liu authored
    This patch will bring support for broadcasting objects larger than 2G.
    
    pickle, zlib, FrameSerializer and Array[Byte] all can not support objects larger than 2G, so this patch introduce LargeObjectSerializer to serialize broadcast objects, the object will be serialized and compressed into small chunks, it also change the type of Broadcast[Array[Byte]]] into Broadcast[Array[Array[Byte]]]].
    
    Testing for support broadcast objects larger than 2G is slow and memory hungry, so this is tested manually, could be added into SparkPerf.
    
    Author: Davies Liu <davies@databricks.com>
    Author: Davies Liu <davies.liu@gmail.com>
    
    Closes #2659 from davies/huge and squashes the following commits:
    
    7b57a14 [Davies Liu] add more tests for broadcast
    28acff9 [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    a2f6a02 [Davies Liu] bug fix
    4820613 [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    5875c73 [Davies Liu] address comments
    10a349b [Davies Liu] address comments
    0c33016 [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    6182c8f [Davies Liu] Merge branch 'master' into huge
    d94b68f [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    2514848 [Davies Liu] address comments
    fda395b [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    1c2d928 [Davies Liu] fix scala style
    091b107 [Davies Liu] broadcast objects larger than 2G
    4a377aff
    History
    [SPARK-3721] [PySpark] broadcast objects larger than 2G
    Davies Liu authored
    This patch will bring support for broadcasting objects larger than 2G.
    
    pickle, zlib, FrameSerializer and Array[Byte] all can not support objects larger than 2G, so this patch introduce LargeObjectSerializer to serialize broadcast objects, the object will be serialized and compressed into small chunks, it also change the type of Broadcast[Array[Byte]]] into Broadcast[Array[Array[Byte]]]].
    
    Testing for support broadcast objects larger than 2G is slow and memory hungry, so this is tested manually, could be added into SparkPerf.
    
    Author: Davies Liu <davies@databricks.com>
    Author: Davies Liu <davies.liu@gmail.com>
    
    Closes #2659 from davies/huge and squashes the following commits:
    
    7b57a14 [Davies Liu] add more tests for broadcast
    28acff9 [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    a2f6a02 [Davies Liu] bug fix
    4820613 [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    5875c73 [Davies Liu] address comments
    10a349b [Davies Liu] address comments
    0c33016 [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    6182c8f [Davies Liu] Merge branch 'master' into huge
    d94b68f [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    2514848 [Davies Liu] address comments
    fda395b [Davies Liu] Merge branch 'master' of github.com:apache/spark into huge
    1c2d928 [Davies Liu] fix scala style
    091b107 [Davies Liu] broadcast objects larger than 2G