[
https://issues.apache.org/jira/browse/HUDI-7468?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lin Liu reassigned HUDI-7468:
-----------------------------
Assignee: Lin Liu
> TestHoodieDeltaStreamerSchemaEvolutionQuick
> -------------------------------------------
>
> Key: HUDI-7468
> URL: https://issues.apache.org/jira/browse/HUDI-7468
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: Lin Liu
> Assignee: Lin Liu
> Priority: Major
>
> {code:java}
> [ERROR] Tests run: 29, Failures: 0, Errors: 3, Skipped: 0, Time elapsed:
> 514.307 s <<< FAILURE! - in
> org.apache.hudi.utilities.deltastreamer.TestHoodieDeltaStreamerSchemaEvolutionQuick
> [ERROR] testReorderingColumn{String, Boolean, Boolean, Boolean}[1] Time
> elapsed: 13.21 s <<< ERROR!
> org.apache.hudi.exception.SchemaCompatibilityException: Incoming batch schema
> is not compatible with the table's one
> at
> org.apache.hudi.HoodieSchemaUtils$.deduceWriterSchema(HoodieSchemaUtils.scala:179)
> at
> org.apache.hudi.HoodieSparkSqlWriter$.deduceWriterSchema(HoodieSparkSqlWriter.scala:147)
> at
> org.apache.hudi.HoodieSparkSqlWriter.deduceWriterSchema(HoodieSparkSqlWriter.scala)
> at
> org.apache.hudi.utilities.streamer.StreamSync.getDeducedSchemaProvider(StreamSync.java:671)
> at
> org.apache.hudi.utilities.streamer.StreamSync.lambda$fetchNextBatchFromSource$5(StreamSync.java:612)
> at org.apache.hudi.common.util.Option.map(Option.java:112)
> at
> org.apache.hudi.utilities.streamer.StreamSync.fetchNextBatchFromSource(StreamSync.java:612)
> at
> org.apache.hudi.utilities.streamer.StreamSync.fetchFromSourceAndPrepareRecords(StreamSync.java:524)
> at
> org.apache.hudi.utilities.streamer.StreamSync.readFromSource(StreamSync.java:497)
> at
> org.apache.hudi.utilities.streamer.StreamSync.syncOnce(StreamSync.java:400)
> at
> org.apache.hudi.utilities.streamer.HoodieStreamer$StreamSyncService.ingestOnce(HoodieStreamer.java:855)
> at
> org.apache.hudi.utilities.ingestion.HoodieIngestionService.startIngestion(HoodieIngestionService.java:72)
> at org.apache.hudi.common.util.Option.ifPresent(Option.java:101)
> at
> org.apache.hudi.utilities.streamer.HoodieStreamer.sync(HoodieStreamer.java:211)
> at
> org.apache.hudi.utilities.deltastreamer.TestHoodieDeltaStreamerSchemaEvolutionQuick.testReorderingColumn(TestHoodieDeltaStreamerSchemaEvolutionQuick.java:327)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
