SparkSQLJava：线程"main"org.apache.spark.异常

Question

我正在看一张桌子。其中一列包含压缩（二进制）数据。我正在解压缩这些数据并存储在另一个RDD中。它给出了以下错误：

线程“main”组织中出现异常。阿帕奇。火花SparkException：作业因阶段失败而中止：阶段2.0中的任务0失败1次，最近的失败：阶段2.0中的任务0.0丢失（TID 2，localhost，executor driver）：java。util。同时发生的ExecutionException：java。lang.异常：未能编译：org。科德豪斯。平民编译器。CompileException：文件'已生成。java’，第36行，第31列：名为“toString”的方法不在任何封闭类或任何超类型中声明，也不通过静态导入声明

代码：

Dataset<Row> df = spark  .read()  .format("jdbc")  .options(options)  
.load().limit(10);

JavaRDD<ConfigObject> 
configObjs=df.as(Encoders.bean(ConfigObject.class)).javaRDD();

JavaRDD<ConfigObjectResult> configObjsResult=configObjs.map(obj -> {
ConfigObjectResult confObjRes= new ConfigObjectResult();
confObjRes.setConfigID(obj.getConfigID());
confObjRes.setAgentVersion(obj.getAgentVersion());
confObjRes.setUncompressedDoc(Compressor.getInstance().
unCompressData(obj.getCompressedDoc()));
confObjRes.setCreationDate(obj.getCreationDate());
    return  confObjRes;
});

Answer 1

CreationDate是数据库中的时间戳。这是我的Obj中的一个字符串。在将时间戳转换为字符串后，它工作了。