[
https://issues.apache.org/jira/browse/HUDI-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ethan Guo updated HUDI-7154:
----------------------------
Description:
Hudi Streamer with row writer enabled hits NPE with empty batch (the checkpoint
has advanced)
{code:java}
java.lang.NullPointerException
at
org.apache.hudi.HoodieSparkSqlWriter$.getBulkInsertRowConfig(HoodieSparkSqlWriter.scala:1190)
at
org.apache.hudi.HoodieSparkSqlWriter.getBulkInsertRowConfig(HoodieSparkSqlWriter.scala)
at
org.apache.hudi.utilities.streamer.StreamSync.prepareHoodieConfigForRowWriter(StreamSync.java:801)
at
org.apache.hudi.utilities.streamer.StreamSync.writeToSink(StreamSync.java:939)
at
org.apache.hudi.utilities.streamer.StreamSync.writeToSinkAndDoMetaSync(StreamSync.java:819)
at
org.apache.hudi.utilities.streamer.StreamSync.syncOnce(StreamSync.java:458)
at
org.apache.hudi.utilities.streamer.HoodieStreamer$StreamSyncService.ingestOnce(HoodieStreamer.java:850)
at org.apache.hudi.common.util.Option.ifPresent(Option.java:97) {code}
was:
{code:java}
java.lang.NullPointerException
at
org.apache.hudi.HoodieSparkSqlWriter$.getBulkInsertRowConfig(HoodieSparkSqlWriter.scala:1190)
at
org.apache.hudi.HoodieSparkSqlWriter.getBulkInsertRowConfig(HoodieSparkSqlWriter.scala)
at
org.apache.hudi.utilities.streamer.StreamSync.prepareHoodieConfigForRowWriter(StreamSync.java:801)
at
org.apache.hudi.utilities.streamer.StreamSync.writeToSink(StreamSync.java:939)
at
org.apache.hudi.utilities.streamer.StreamSync.writeToSinkAndDoMetaSync(StreamSync.java:819)
at
org.apache.hudi.utilities.streamer.StreamSync.syncOnce(StreamSync.java:458)
at
org.apache.hudi.utilities.streamer.HoodieStreamer$StreamSyncService.ingestOnce(HoodieStreamer.java:850)
at org.apache.hudi.common.util.Option.ifPresent(Option.java:97) {code}
> Hudi Streamer with row writer enabled hits NPE with empty batch
> ---------------------------------------------------------------
>
> Key: HUDI-7154
> URL: https://issues.apache.org/jira/browse/HUDI-7154
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: Ethan Guo
> Priority: Blocker
> Fix For: 0.14.1
>
>
> Hudi Streamer with row writer enabled hits NPE with empty batch (the
> checkpoint has advanced)
> {code:java}
> java.lang.NullPointerException
> at
> org.apache.hudi.HoodieSparkSqlWriter$.getBulkInsertRowConfig(HoodieSparkSqlWriter.scala:1190)
> at
> org.apache.hudi.HoodieSparkSqlWriter.getBulkInsertRowConfig(HoodieSparkSqlWriter.scala)
> at
> org.apache.hudi.utilities.streamer.StreamSync.prepareHoodieConfigForRowWriter(StreamSync.java:801)
> at
> org.apache.hudi.utilities.streamer.StreamSync.writeToSink(StreamSync.java:939)
> at
> org.apache.hudi.utilities.streamer.StreamSync.writeToSinkAndDoMetaSync(StreamSync.java:819)
> at
> org.apache.hudi.utilities.streamer.StreamSync.syncOnce(StreamSync.java:458)
> at
> org.apache.hudi.utilities.streamer.HoodieStreamer$StreamSyncService.ingestOnce(HoodieStreamer.java:850)
> at org.apache.hudi.common.util.Option.ifPresent(Option.java:97) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
