From 7b971683f751a2a955d160ac426735343a56a8b3 Mon Sep 17 00:00:00 2001 From: Uros Bojanic Date: Sun, 26 Jul 2026 22:28:38 +0000 Subject: [PATCH] Initial commit --- .../execution/streaming/checkpointing/AsyncOffsetSeqLog.scala | 2 +- .../sql/execution/streaming/checkpointing/HDFSMetadataLog.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/AsyncOffsetSeqLog.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/AsyncOffsetSeqLog.scala index 14fb4620527c0..c2ae9ac0fae6b 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/AsyncOffsetSeqLog.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/AsyncOffsetSeqLog.scala @@ -83,7 +83,7 @@ class AsyncOffsetSeqLog( * to indicate some write error. */ def addAsync(batchId: Long, metadata: OffsetSeqBase): CompletableFuture[(Long, Boolean)] = { - require(metadata != null, "'null' metadata cannot written to a metadata log") + require(metadata != null, "'null' metadata cannot be written to a metadata log") def issueAsyncWrite(batchId: Long): CompletableFuture[Long] = { lastCommitIssuedTimestampMs.set(clock.getTimeMillis()) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/HDFSMetadataLog.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/HDFSMetadataLog.scala index b06a90de44c48..3f2271ac2b2c2 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/HDFSMetadataLog.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/checkpointing/HDFSMetadataLog.scala @@ -133,7 +133,7 @@ class HDFSMetadataLog[T <: AnyRef : ClassTag]( * metadata has already been stored, this method will return `false`. */ override def add(batchId: Long, metadata: T): Boolean = { - require(metadata != null, "'null' metadata cannot written to a metadata log") + require(metadata != null, "'null' metadata cannot be written to a metadata log") val res = addNewBatchByStream(batchId) { output => serialize(metadata, output) } if (metadataCacheEnabled && res) batchCache.put(batchId, metadata) res