I have a dataframe va with two column vertex1 and vertex2. va has

6731710209 rows

I want to compute similarity between vertex1 and vertex2. To do that I have the following UDF function:

weight_udf = udf(edgeWeight, FloatType())
va = va.withColumn('similarity', weight_udf(va.vertex1, va.vertex2))

When running the code I get the following strange error:

#
# A fatal error has been detected by the Java Runtime Environment:

    #
    #  SIGSEGV (0xb) at pc=0x00002b5fe21d0ba0, pid=67441, tid=0x00002b605e421700
    #
    # JRE version: Java(TM) SE Runtime Environment (8.0_121-b13) (build 1.8.0_121-b13)
    # Java VM: Java HotSpot(TM) 64-Bit Server VM (25.121-b13 mixed mode linux-amd64 compressed oops)
    # Problematic frame:
    # J 12180 C2 org.apache.spark.sql.execution.UnsafeFixedWidthAggregationMap$1.next()Z (60 bytes) @ 0x00002b5fe21d0ba0 [0x00002b5fe21d0ac0+0xe0]
    #
    # Core dump written. Default location: /project/6008168/moudi/job/core or core.67441
    #
    # An error report file with more information is saved as:
    # /project/6008168/moudi/job/hs_err_pid67441.log
    [thread 47692633986816 also had an error]
    #
    # If you would like to submit a bug report, please visit:
    #   http://bugreport.java.com/bugreport/crash.jsp
    #
Aborted (core dumped)

I cannot figure out what is the problem. Can someone please help?

0 Answers