[
https://issues.apache.org/jira/browse/HUDI-8944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Davis Zhang closed HUDI-8944.
-----------------------------
Resolution: Fixed
> EMR testing issue: cannot cast string to checkpoint
> ---------------------------------------------------
>
> Key: HUDI-8944
> URL: https://issues.apache.org/jira/browse/HUDI-8944
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: Davis Zhang
> Assignee: Davis Zhang
> Priority: Major
>
> {code:java}
> 25/01/30 23:21:33 INFO SparkContext: Successfully stopped SparkContext
> Exception in thread "main"
> org.apache.hudi.utilities.ingestion.HoodieIngestionException: Ingestion
> service was shut down with exception.
> at
> org.apache.hudi.utilities.ingestion.HoodieIngestionService.startIngestion(HoodieIngestionService.java:67)
> at org.apache.hudi.common.util.Option.ifPresent(Option.java:101)
> at
> org.apache.hudi.utilities.streamer.HoodieStreamer.sync(HoodieStreamer.java:224)
> at
> org.apache.hudi.utilities.streamer.HoodieStreamer.main(HoodieStreamer.java:644)
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:498)
> at
> org.apache.spark.deploy.JavaMainApplication.start(SparkApplication.scala:52)
> at
> org.apache.spark.deploy.SparkSubmit.org$apache$spark$deploy$SparkSubmit$$runMain(SparkSubmit.scala:1029)
> at
> org.apache.spark.deploy.SparkSubmit.doRunMain$1(SparkSubmit.scala:194)
> at org.apache.spark.deploy.SparkSubmit.submit(SparkSubmit.scala:217)
> at org.apache.spark.deploy.SparkSubmit.doSubmit(SparkSubmit.scala:91)
> at
> org.apache.spark.deploy.SparkSubmit$$anon$2.doSubmit(SparkSubmit.scala:1120)
> at org.apache.spark.deploy.SparkSubmit$.main(SparkSubmit.scala:1129)
> at org.apache.spark.deploy.SparkSubmit.main(SparkSubmit.scala)
> Caused by: java.util.concurrent.ExecutionException:
> org.apache.hudi.exception.HoodieException: java.lang.String cannot be cast to
> org.apache.hudi.common.table.checkpoint.Checkpoint
> at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> at
> org.apache.hudi.async.HoodieAsyncService.waitForShutdown(HoodieAsyncService.java:102)
> at
> org.apache.hudi.utilities.ingestion.HoodieIngestionService.startIngestion(HoodieIngestionService.java:65)
> ... 15 more
> Caused by: org.apache.hudi.exception.HoodieException: java.lang.String cannot
> be cast to org.apache.hudi.common.table.checkpoint.Checkpoint
> at
> org.apache.hudi.utilities.streamer.HoodieStreamer$StreamSyncService.lambda$startService$1(HoodieStreamer.java:865)
> at
> java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
> 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:750)
> Caused by: java.lang.ClassCastException: java.lang.String cannot be cast to
> org.apache.hudi.common.table.checkpoint.Checkpoint
> at
> org.apache.hudi.utilities.sources.RowSource.lambda$readFromCheckpoint$0(RowSource.java:68)
> at org.apache.hudi.common.util.Option.map(Option.java:112)
> at
> org.apache.hudi.utilities.sources.RowSource.readFromCheckpoint(RowSource.java:62)
> at org.apache.hudi.utilities.sources.Source.fetchNext(Source.java:170)
> at
> org.apache.hudi.utilities.streamer.SourceFormatAdapter.fetchNewDataInAvroFormat(SourceFormatAdapter.java:184)
> at
> org.apache.hudi.utilities.streamer.StreamSync.fetchNextBatchFromSource(StreamSync.java:710)
> at
> org.apache.hudi.utilities.streamer.StreamSync.fetchFromSourceAndPrepareRecords(StreamSync.java:582)
> at
> org.apache.hudi.utilities.streamer.StreamSync.readFromSource(StreamSync.java:554)
> at
> org.apache.hudi.utilities.streamer.StreamSync.syncOnce(StreamSync.java:464)
> at
> org.apache.hudi.utilities.streamer.HoodieStreamer$StreamSyncService.lambda$startService$1(HoodieStreamer.java:827)
> ... 4 more {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
