Lin Liu created HUDI-7468:
-----------------------------

             Summary: TestHoodieDeltaStreamerSchemaEvolutionQuick
                 Key: HUDI-7468
                 URL: https://issues.apache.org/jira/browse/HUDI-7468
             Project: Apache Hudi
          Issue Type: Bug
            Reporter: Lin Liu


{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)

Reply via email to