#scala #apache-spark #hive #apache-spark-sql #orc
#scala #apache-spark #улей #apache-spark-sql #orc
Вопрос:
программа чтения встроенного orc spark работает не так, как ожидалось. пожалуйста, ознакомьтесь с деталями ниже
import org.apache.spark.sql.{Dataset, Encoders, SparkSession}
case class GateDoc(var xml: Array[Byte], var cknid: String = null)
spark.conf.set("spark.sql.orc.impl","native")
import spark.implicits._
val df = spark.read.schema(Encoders.product[GateDoc].schema).orc(inputFile).as[GateDoc] // problem here while reading throws below mentioned exception
df.write.orc(op)
выдает
java.lang.NegativeArraySizeException
at org.apache.orc.impl.TreeReaderFactory$BytesColumnVectorUtil.commonReadByteArrays(TreeReaderFactory.java:1506)
at org.apache.orc.impl.TreeReaderFactory$BytesColumnVectorUtil.readOrcByteArrays(TreeReaderFactory.java:1528)
at org.apache.orc.impl.TreeReaderFactory$BinaryTreeReader.nextVector(TreeReaderFactory.java:878)
at org.apache.orc.impl.TreeReaderFactory$StructTreeReader.nextBatch(TreeReaderFactory.java:2012)
at org.apache.orc.impl.RecordReaderImpl.nextBatch(RecordReaderImpl.java:1284)
at org.apache.spark.sql.execution.datasources.orc.OrcColumnarBatchReader.nextBatch(OrcColumnarBatchReader.java:227)
at org.apache.spark.sql.execution.datasources.orc.OrcColumnarBatchReader.nextKeyValue(OrcColumnarBatchReader.java:109)
at org.apache.spark.sql.execution.datasources.RecordReaderIterator.hasNext(RecordReaderIterator.scala:39)
at org.apache.spark.sql.execution.datasources.FileScanRDD$$anon$1.hasNext(FileScanRDD.scala:130)
at org.apache.spark.sql.execution.datasources.FileScanRDD$$anon$1.nextIterator(FileScanRDD.scala:215)
at org.apache.spark.sql.execution.datasources.FileScanRDD$$anon$1.hasNext(FileScanRDD.scala:130)
at org.apache.spark.sql.catalyst.expressions.GeneratedClass$GeneratedIteratorForCodegenStage1.scan_nextBatch_0$(Unknown Source)
at org.apache.spark.sql.catalyst.expressions.GeneratedClass$GeneratedIteratorForCodegenStage1.processNext(Unknown Source)
at org.apache.spark.sql.execution.BufferedRowIterator.hasNext(BufferedRowIterator.java:43)
at org.apache.spark.sql.execution.WholeStageCodegenExec$$anonfun$13$$anon$1.hasNext(WholeStageCodegenExec.scala:636)
at org.apache.spark.sql.execution.datasources.FileFormatWriter$.org$apache$spark$sql$execution$datasources$FileFormatWriter$$executeTask(FileFormatWriter.scala:232)
at org.apache.spark.sql.execution.datasources.FileFormatWriter$$anonfun$write$1.apply(FileFormatWriter.scala:170)
at org.apache.spark.sql.execution.datasources.FileFormatWriter$$anonfun$write$1.apply(FileFormatWriter.scala:169)
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:90)
at org.apache.spark.scheduler.Task.run(Task.scala:123)
at org.apache.spark.executor.Executor$TaskRunner$$anonfun$10.apply(Executor.scala:408)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:1360)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:414)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Однако он хорошо работает при использовании spark.sql.orc.impl = hive
import org.apache.spark.sql.{Dataset, Encoders, SparkSession}
case class GateDoc(var xml: Array[Byte], var cknid: String = null)
spark.conf.set("spark.sql.orc.impl","hive")
import spark.implicits._
val df = spark.read.schema(Encoders.product[GateDoc].schema).orc(inputFile).as[GateDoc]
df.write.orc(op)
Я хорошо понимаю, почему java.lang.Исключение NegativeArraySizeException выбрасывается в моем usecase, но почему оно инициализирует поле типа массива моего класса case с отрицательным значением?
Я также проверил метаданные нескольких разделов, как показано ниже
java -jar/usr/lib/spark/jars/orc-tools-1.5.5-uber.jar data part-00.snappy.orc
java -jar /usr/lib/spark/jars/orc-tools-1.5.5-uber.jar meta part-00.snappy.orc
который, кажется, в порядке
Более подробная информация об окружающей среде :
Scala version 2.11.12
Spark Version 2.4.4
Orc Version 1.5.5
EMR emr-5.29.0
Пожалуйста, помогите мне. Я чувствую, что в orc native reader есть какая-то ошибка.
Комментарии:
1. Можете ли вы поделиться некоторыми своими данными, чтобы мы могли попытаться воспроизвести проблему?
2. @kfkhalili я не могу поделиться данными… я предоставил схему во входных данных… данные слишком велики — около 1,1 ТБ, сжатые мгновенно… в журнале неясно, для какого раздела не удается десериализовать…
3. Можете ли вы подробнее рассказать о том, как создаются эти файлы ORC, поскольку цель изменяемого параметра — учесть различия в том, как были записаны данные spark.apache.org/docs/latest/sql-data-sources-orc.html
4. @mazaneicha Входные данные были созданы вышестоящими заданиями spark, которые использовали orc.impl=native, и поле xml GateDoc класса case установлено как (doc.ToXML().getBytes(«UTF-8»)) ….. здесь поле документа — это ворота ( gate.ac.uk ) Документ, который был сгенерирован HtmlContent.