This is an automated email from the ASF dual-hosted git repository.
kerwin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new d25e55d091 [hotfix] [doc] Fix some typos for document and test case.
(#5055)
d25e55d091 is described below
commit d25e55d091e8c662ad05686417728163de28becd
Author: yangjf2019 <[email protected]>
AuthorDate: Thu Feb 13 11:18:50 2025 +0800
[hotfix] [doc] Fix some typos for document and test case. (#5055)
---
docs/content/maintenance/dedicated-compaction.md | 2 +-
.../apache/paimon/spark/procedure/RemoveOrphanFilesProcedureTest.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/content/maintenance/dedicated-compaction.md
b/docs/content/maintenance/dedicated-compaction.md
index 63e0aa5e66..6e8abc22e1 100644
--- a/docs/content/maintenance/dedicated-compaction.md
+++ b/docs/content/maintenance/dedicated-compaction.md
@@ -34,7 +34,7 @@ enable `'lock.enabled'` option for the catalog.
{{< /hint >}}
By default, Paimon supports concurrent writing to different partitions. A
recommended mode is that streaming
-job writes records to Paimon's latest partition; Simultaneously batch job
(overwrite) writes records to the
+job writes records to Paimon's latest partition, Simultaneously batch job
(overwrite) writes records to the
historical partition.
{{< img src="/img/multiple-writers.png">}}
diff --git
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedureTest.scala
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedureTest.scala
index 248ba863cb..a205e69fd7 100644
---
a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedureTest.scala
+++
b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedureTest.scala
@@ -204,7 +204,7 @@ class RemoveOrphanFilesProcedureTest extends
PaimonSparkTestBase {
checkAnswer(
spark.sql(
- s"CALL sys.remove_orphan_files(table => 'T', older_than =>
'$older_than1', mode => 'diSTributed')"),
+ s"CALL sys.remove_orphan_files(table => 'T', older_than =>
'$older_than1', mode => 'distributed')"),
Row(1, 1) :: Nil)
val older_than2 = DateTimeUtils.formatLocalDateTime(
