[
https://issues.apache.org/jira/browse/HUDI-7071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kwang updated HUDI-7071:
------------------------
Description:
Clustering/Compaction job throw follow exception, the final result returns -1
and the job's state is success.
{code:java}
ERROR UtilHelpers: Cluster failed
org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in
stage 4.0 failed 2 times, most recent failure: Lost task 0.1 in stage 4.0 (TID
5) (lenghong-slave-prd-10-197-3-139.v-bj-5.vivo.lan executor 1):
org.apache.hudi.exception.HoodieException: unable to read next record from
parquet file
at
org.apache.hudi.common.util.ParquetReaderIterator.hasNext(ParquetReaderIterator.java:54)
at
org.apache.hudi.common.util.collection.MappingIterator.hasNext(MappingIterator.java:39)
at
org.apache.hudi.common.util.collection.MappingIterator.hasNext(MappingIterator.java:39)
at
org.apache.hudi.client.utils.ConcatenatingIterator.hasNext(ConcatenatingIterator.java:45)
{code}
was:Clustering/Compaction job throw exception `
org.apache.hudi.exception.HoodieException: unable to read next record from
parquet file `, the final result returns -1 and the job's state is success.
> Compaction/Clustering job not fail when throw HoodieException
> -------------------------------------------------------------
>
> Key: HUDI-7071
> URL: https://issues.apache.org/jira/browse/HUDI-7071
> Project: Apache Hudi
> Issue Type: Improvement
> Reporter: kwang
> Priority: Major
>
> Clustering/Compaction job throw follow exception, the final result returns -1
> and the job's state is success.
> {code:java}
> ERROR UtilHelpers: Cluster failed
> org.apache.spark.SparkException: Job aborted due to stage failure: Task 0 in
> stage 4.0 failed 2 times, most recent failure: Lost task 0.1 in stage 4.0
> (TID 5) (lenghong-slave-prd-10-197-3-139.v-bj-5.vivo.lan executor 1):
> org.apache.hudi.exception.HoodieException: unable to read next record from
> parquet file
> at
> org.apache.hudi.common.util.ParquetReaderIterator.hasNext(ParquetReaderIterator.java:54)
> at
> org.apache.hudi.common.util.collection.MappingIterator.hasNext(MappingIterator.java:39)
> at
> org.apache.hudi.common.util.collection.MappingIterator.hasNext(MappingIterator.java:39)
> at
> org.apache.hudi.client.utils.ConcatenatingIterator.hasNext(ConcatenatingIterator.java:45)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
